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

6 statements  

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

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

2 

3from .service import customer_session as customer_session_service 1a

4 

5 

6@actor( 1a

7 actor_name="customer_session.delete_expired", 

8 cron_trigger=CronTrigger(hour=0, minute=0), 

9 priority=TaskPriority.LOW, 

10) 

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

12 async with AsyncSessionMaker() as session: 

13 await customer_session_service.delete_expired(session)