add task done to broadcast queue method

This commit is contained in:
Timothy Pogue 2022-11-02 13:30:42 -06:00
parent e25dea7e0e
commit d848c27283

View File

@ -197,6 +197,7 @@ class ApiServer(RPCHandler):
# Get data from queue # Get data from queue
message: WSMessageSchemaType = await async_queue.get() message: WSMessageSchemaType = await async_queue.get()
logger.debug(f"Found message of type: {message.get('type')}") logger.debug(f"Found message of type: {message.get('type')}")
async_queue.task_done()
# Broadcast it # Broadcast it
await self._ws_channel_manager.broadcast(message) await self._ws_channel_manager.broadcast(message)
except asyncio.CancelledError: except asyncio.CancelledError: