Fix: Gracefully handle exceptions in PubSub message retrieval

An exception was observed in the logs when retrieving messages from the Redis subscription. This change adds a try-except block to catch potential exceptions during the `get_message` call and handle them gracefully by returning None.

This prevents the subscription loop from crashing and improves the overall stability of the PubSub system.

Signed-off-by: Denys Fedoryshchenko <[email protected]>

Author: nuclearcat

api/pubsub.py

@@ -135,9 +135,14 @@ async def listen(self, sub_id, user=None):
                                f"not owned by {user}")
         while True:
             self._subscriptions[sub_id]['last_poll'] = datetime.utcnow()
-            msg = await sub['redis_sub'].get_message(
-                ignore_subscribe_messages=True, timeout=1.0
-            )
+            msg = None
+            try:
+                msg = await sub['redis_sub'].get_message(
+                    ignore_subscribe_messages=True, timeout=1.0
+                )
+            except Exception as e:
+                return None  # Handle any exceptions gracefully
+
             if msg is None:
                 continue
             msg_data = json.loads(msg['data'])