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

6 statements  

« prev     ^ index     » next       coverage.py v7.10.6, created at 2025-12-05 15:52 +0000

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

2 

3from .service import processor_transaction as processor_transaction_service 1a

4 

5 

6@actor( 1a

7 actor_name="processor_transaction.sync_stripe", 

8 cron_trigger=CronTrigger(minute=5), 

9 priority=TaskPriority.LOW, 

10) 

11async def sync_stripe() -> None: 1a

12 async with AsyncSessionMaker() as session: 

13 await processor_transaction_service.sync_stripe(session)