Reraise CancelledError in connect() (#170)

NoneGG · Oct 19, 2020 · 642480d · 642480d
1 parent 734ce29
commit 642480d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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