From ac947ab5277aad09eabe40f6281637157ca9a53d Mon Sep 17 00:00:00 2001 From: m5l14i11 Date: Thu, 10 Oct 2024 01:32:48 +0300 Subject: [PATCH] upd --- coral/exchange/ws/_bybit.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/coral/exchange/ws/_bybit.py b/coral/exchange/ws/_bybit.py index 9f07ac95..609e569d 100644 --- 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():