Coverage for polar/processor_transaction/tasks.py: 67%

1from polar.worker import AsyncSessionMaker, CronTrigger, TaskPriority, actor 

2 

3from .service import processor_transaction as processor_transaction_service 

4 

5 

6@actor( 

7 actor_name="processor_transaction.sync_stripe", 

8 cron_trigger=CronTrigger(minute=5), 

9 priority=TaskPriority.LOW, 

10) 

11async def sync_stripe() -> None: 

12 async with AsyncSessionMaker() as session: 

13 await processor_transaction_service.sync_stripe(session)