timeout to untighten ws python loop (#821)

Co-authored-by: Igor Loskutov <igor.loskutoff@gmail.com>
This commit is contained in:
2026-01-20 16:29:09 -05:00
committed by GitHub
parent d83c4a30b4
commit 8a293882ad

View File

@@ -99,7 +99,8 @@ class WebsocketManager:
async def _pubsub_data_reader(self, pubsub_subscriber):
while True:
message = await pubsub_subscriber.get_message(
ignore_subscribe_messages=True
ignore_subscribe_messages=True,
timeout=1.0,
)
if message is not None:
room_id = message["channel"].decode("utf-8")