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

sentry_sdk/integrations/redis/_sync_common.py

@@ -42,13 +42,21 @@ def sentry_patched_execute(self, *args, **kwargs):
             origin=SPAN_ORIGIN,
         ) as span:
             with capture_internal_exceptions():
+                command_seq = None
+                if getattr(self, "_execution_strategy", None) and getattr(
+                    self._execution_strategy, "command_queue", None
+                ):
+                    command_seq = self._execution_strategy.command_queue
+                else:
+                    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,
         },
     )