From 92ac66560f355ec5ba0d010b342d97f68f843425 Mon Sep 17 00:00:00 2001 From: cogisum Date: Fri, 18 Jul 2025 20:43:24 +0800 Subject: [PATCH] try to reconect on some exceptions --- binance/ws/reconnecting_websocket.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/binance/ws/reconnecting_websocket.py b/binance/ws/reconnecting_websocket.py index b39cb2a4..8e4c5f89 100644 --- a/binance/ws/reconnecting_websocket.py +++ b/binance/ws/reconnecting_websocket.py @@ -15,9 +15,9 @@ pass try: - from websockets.exceptions import ConnectionClosedError # type: ignore + from websockets.exceptions import ConnectionClosedError, ConnectionClosedOK # type: ignore except ImportError: - from websockets import ConnectionClosedError # type: ignore + from websockets import ConnectionClosedError, ConnectionClosedOK # type: ignore Proxy = None @@ -226,7 +226,9 @@ async def _read_loop(self): asyncio.IncompleteReadError, gaierror, ConnectionClosedError, + ConnectionClosedOK, BinanceWebsocketClosed, + BinanceWebsocketUnableToConnect, ) as e: # reports errors and continue loop self._log.error(f"{e.__class__.__name__} ({e})") @@ -236,7 +238,6 @@ async def _read_loop(self): "m": f"{e}", }) except ( - BinanceWebsocketUnableToConnect, BinanceWebsocketQueueOverflow, Exception, ) as e: