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

1import structlog 1 ctx1a

2 

3from polar.logging import Logger 1 ctx1a

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

5 

6from .service import auth as auth_service 1 ctx1a

7 

8log: Logger = structlog.get_logger() 1 ctx1a

9 

10 

11@actor( 1 ctx1a

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: 1 ctx1a

17 async with AsyncSessionMaker() as session: 

18 await auth_service.delete_expired(session)