From 8a293882ad2cdb178ab0e58e2fbee18385a868b1 Mon Sep 17 00:00:00 2001 From: Igor Monadical Date: Tue, 20 Jan 2026 16:29:09 -0500 Subject: [PATCH] timeout to untighten ws python loop (#821) Co-authored-by: Igor Loskutov --- server/reflector/ws_manager.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/reflector/ws_manager.py b/server/reflector/ws_manager.py index a1f620c4..83201ce1 100644 --- a/server/reflector/ws_manager.py +++ b/server/reflector/ws_manager.py @@ -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")