Coverage for polar/auth/tasks.py: 78%

1import structlog 

2 

3from polar.logging import Logger 

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

5 

6from .service import auth as auth_service 

7 

8log: Logger = structlog.get_logger() 

9 

10 

11@actor( 

12 actor_name="auth.delete_expired", 

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

14 priority=TaskPriority.LOW, 

15) 

16async def auth_delete_expired() -> None: 

17 async with AsyncSessionMaker() as session: 

18 await auth_service.delete_expired(session)