Fix async (#2673)

1 files changed, 3 insertions, 7 deletions

diff --git a/redis/asyncio/client.py b/redis/asyncio/client.py
index 7986b11..3e6626a 100644
--- a/redis/asyncio/client.py
+++ b/redis/asyncio/client.py
@@ -1227,13 +1227,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):
         """