Coverage for polar/event/tasks.py: 75%

1import uuid 

2from collections.abc import Sequence 

3 

4from polar.worker import AsyncSessionMaker, TaskPriority, actor 

5 

6from .service import event as event_service 

7 

8 

9@actor(actor_name="event.ingested", priority=TaskPriority.LOW) 

10async def event_ingested(event_ids: Sequence[uuid.UUID]) -> None: 

11 async with AsyncSessionMaker() as session: 

12 await event_service.ingested(session, event_ids)