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

1from logging import Logger 

2 

3import structlog 

4 

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

6 

7from .service import email_update as email_update_service 

8 

9log: Logger = structlog.get_logger() 

10 

11 

12@actor( 

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: 

18 async with AsyncSessionMaker() as session: 

19 await email_update_service.delete_expired_record(session)