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

8 statements  

« prev     ^ index     » next       coverage.py v7.10.6, created at 2025-12-05 17:15 +0000

1import uuid 1a

2from collections.abc import Sequence 1a

3 

4from polar.worker import AsyncSessionMaker, TaskPriority, actor 1a

5 

6from .service import event as event_service 1a

7 

8 

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

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

11 async with AsyncSessionMaker() as session: 

12 await event_service.ingested(session, event_ids)