close loop4.3.7

1 files changed, 3 insertions, 7 deletions

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):
         """