From 519c1ae2b2f20cd51b1c091709ae5a3ea5fad072 Mon Sep 17 00:00:00 2001 From: "Chayim I. Kirshen" Date: Tue, 4 Apr 2023 12:35:08 +0300 Subject: close loop --- redis/asyncio/client.py | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) (limited to 'redis/asyncio/client.py') diff --git a/redis/asyncio/client.py b/redis/asyncio/client.py index f5d8b01..8628ff7 100644 --- a/redis/asyncio/client.py +++ b/redis/asyncio/client.py @@ -1185,13 +1185,9 @@ class Pipeline(Redis): # lgtm [py/init-calls-subclass] command_name, self.shard_hint ) self.connection = conn - try: - return await asyncio.shield( - self._try_send_command_parse_response(conn, *args, **options) - ) - except asyncio.CancelledError: - await conn.disconnect() - raise + return await asyncio.shield( + self._try_send_command_parse_response(conn, *args, **options) + ) def pipeline_execute_command(self, *args, **options): """ -- cgit v1.2.1