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

1from logging import Logger 1 ctx1a

2 

3import structlog 1 ctx1a

4 

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

6 

7from .service import email_update as email_update_service 1 ctx1a

8 

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

10 

11 

12@actor( 1 ctx1a

13 actor_name="email_update.delete_expired_record", 

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

15 priority=TaskPriority.LOW, 

16) 

17async def email_update_delete_expired_record() -> None: 1 ctx1a

18 async with AsyncSessionMaker() as session: 

19 await email_update_service.delete_expired_record(session)