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

1from polar.worker import RedisMiddleware, TaskPriority, actor 

2 

3from .service import send_event 

4 

5 

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

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

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