Reraise CancelledError in PubSub execute

Derived from NoneGG/aredis#182
alisaifee · Jan 16, 2022 · 1068673 · 1068673
1 parent 4772063
commit 1068673
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/coredis/pubsub.py b/coredis/pubsub.py
@@ -117,7 +117,7 @@ async def _execute(self, connection, command, *args):
                 # when connection is reused
                 connection.disconnect()
 
-            return None
+            raise
         except (ConnectionError, TimeoutError) as e:
             connection.disconnect()