diff --git a/aredis/connection.py b/aredis/connection.py index a3be609c..6dc79050 100755 --- a/aredis/connection.py +++ b/aredis/connection.py @@ -413,6 +413,8 @@ async def can_read(self): async def connect(self): try: await self._connect() + except aredis.compat.CancelledError: + raise except Exception as exc: raise ConnectionError() # run any user callbacks. right now the only internal callback