diff --git a/main.py b/main.py
index 9717e212b..7fe932f64 100644
--- a/main.py
+++ b/main.py
@@ -351,7 +351,7 @@ async def inner(mgr):
                                 )
                                 _run_async_update_with_retries(mgr, current_block=current_block)
                                 mgr.pools_to_add_from_contracts = []
-            except websockets.exceptions.ConnectionClosed:
+            except websockets.exceptions.ConnectionClosedError:
                 logger.info("Websocket connection lost. Reconnecting ...")
                 await asyncio.sleep(1)