upd

YieldsLabs · Oct 9, 2024 · ac947ab · ac947ab
1 parent ee8c88b
commit ac947ab
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/coral/exchange/ws/_bybit.py b/coral/exchange/ws/_bybit.py
@@ -208,8 +208,8 @@ async def unsubscribe(self, topic: str):
 
             if topic in self._subscriptions:
                 self._subscriptions.remove(topic)
-                if topic in self._topic_queues:
-                    self._topic_queues.pop(topic)
+            if topic in self._topic_queues:
+                self._topic_queues.pop(topic)
 
     async def get_message(self, topic: str):
         if topic not in self._topic_queues:
@@ -292,6 +292,7 @@ async def _resubscribe_all(self):
 
     async def _handle_reconnect(self):
         if not self.ws:
+            logger.error("WebSocket connection error.")
             return
 
         if self._auth_event.is_set():