Truncate pipeline exception message to a sane size

Fixes #20234.

Author: rohansingh

redis/asyncio/cluster.py

@@ -1593,7 +1593,7 @@ async def _execute(
                     if isinstance(result, Exception):
                         command = " ".join(map(safe_str, cmd.args))
                         msg = (
-                            f"Command # {cmd.position + 1} ({command}) of pipeline "
+                            f"Command # {cmd.position + 1} ({self._truncate_command(command)}) of pipeline "
                             f"caused error: {result.args}"
                         )
                         result.args = (msg,) + result.args[1:]
@@ -1637,6 +1637,11 @@ def mset_nonatomic(
 
         return self
 
+    def _truncate_command(self, command, max_length=100):
+        if len(command) > max_length:
+            return command[:max_length] + "..."
+        return command
+
 
 for command in PIPELINE_BLOCKED_COMMANDS:
     command = command.replace(" ", "_").lower()

redis/client.py

@@ -1514,11 +1514,16 @@ def raise_first_error(self, commands, response):
     def annotate_exception(self, exception, number, command):
         cmd = " ".join(map(safe_str, command))
         msg = (
-            f"Command # {number} ({cmd}) of pipeline "
+            f"Command # {number} ({self._truncate_command(cmd)}) of pipeline "
             f"caused error: {exception.args[0]}"
         )
         exception.args = (msg,) + exception.args[1:]
 
+    def _truncate_command(self, command, max_length=100):
+        if len(command) > max_length:
+            return command[:max_length] + "..."
+        return command
+
     def parse_response(self, connection, command_name, **options):
         result = Redis.parse_response(self, connection, command_name, **options)
         if command_name in self.UNWATCH_COMMANDS: