Coverage for polar/eventstream/tasks.py: 80%

5 statements  

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

1from polar.worker import RedisMiddleware, TaskPriority, actor 1a

2 

3from .service import send_event 1a

4 

5 

6@actor(actor_name="eventstream.publish", priority=TaskPriority.HIGH) 1a

7async def eventstream_publish(event: str, channels: list[str]) -> None: 1a

8 await send_event(RedisMiddleware.get(), event, channels)