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: