From 1068673abd0368beaa23959242987e9a40d81d11 Mon Sep 17 00:00:00 2001 From: Ali-Akber Saifee Date: Sun, 16 Jan 2022 15:51:02 -0800 Subject: [PATCH] Reraise CancelledError in PubSub execute Derived from NoneGG/aredis#182 --- coredis/pubsub.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/coredis/pubsub.py b/coredis/pubsub.py index ee73cea8..12a8152d 100644 --- 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()