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

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

2 

3from .service import customer_session as customer_session_service 

4 

5 

6@actor( 

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: 

12 async with AsyncSessionMaker() as session: 

13 await customer_session_service.delete_expired(session)