fix(redis): Use command_queue instead of command_stack if available (#4404)

This
[commit](redis/redis-py@91be4a0)
in `redis-py` moved away from using the Pipeline's `command_stack` and
is now using `_execution_strategy.command_queue` instead. We need to
adapt to use the new command source if present.

This fixes `redis-latest` in CI.

---------

Co-authored-by: Daniel Szoke <[email protected]>

Author: sentrivana

sentry_sdk/integrations/redis/_sync_common.py

@@ -42,13 +42,19 @@ def sentry_patched_execute(self, *args, **kwargs):
             origin=SPAN_ORIGIN,
         ) as span:
             with capture_internal_exceptions():
+                command_seq = None
+                try:
+                    command_seq = self._execution_strategy.command_queue
+                except AttributeError:
+                    command_seq = self.command_stack
+
                 set_db_data_fn(span, self)
                 _set_pipeline_data(
                     span,
                     is_cluster,
                     get_command_args_fn,
                     False if is_cluster else self.transaction,
-                    self.command_stack,
+                    command_seq,
                 )
 
             return old_execute(self, *args, **kwargs)

sentry_sdk/integrations/redis/utils.py

@@ -106,14 +106,18 @@ def _parse_rediscluster_command(command):
 
 
 def _set_pipeline_data(
-    span, is_cluster, get_command_args_fn, is_transaction, command_stack
+    span,
+    is_cluster,
+    get_command_args_fn,
+    is_transaction,
+    commands_seq,
 ):
     # type: (Span, bool, Any, bool, Sequence[Any]) -> None
     span.set_tag("redis.is_cluster", is_cluster)
     span.set_tag("redis.transaction", is_transaction)
 
     commands = []
-    for i, arg in enumerate(command_stack):
+    for i, arg in enumerate(commands_seq):
         if i >= _MAX_NUM_COMMANDS:
             break
 
@@ -123,7 +127,7 @@ def _set_pipeline_data(
     span.set_data(
         "redis.commands",
         {
-            "count": len(command_stack),
+            "count": len(commands_seq),
             "first_ten": commands,
         },
     )