diff --git a/live_candle_fetcher.py b/live_candle_fetcher.py index a7a0cee..b87cc71 100644 --- a/live_candle_fetcher.py +++ b/live_candle_fetcher.py @@ -164,6 +164,8 @@ class LiveCandleFetcher: while True: try: time.sleep(1) + if not self.info.ws_manager.is_alive(): + raise ConnectionError("WebSocket connection is not alive") if time.time() - self._last_status_log >= 300: if self._last_candle_info: logging.info(f"LiveCandleFetcher running correctly. Last 1m candle collected: {self._last_candle_info[0]} at {self._last_candle_info[1]}")