feat(rq): Add messaging.destination.name attribute to consumer spans

Author: alexander-alderman-webb

sentry_sdk/integrations/rq.py

@@ -99,6 +99,11 @@ def sentry_patched_perform_job(
                         if func_name is not None:
                             span.set_attribute(SPANDATA.CODE_FUNCTION_NAME, func_name)
 
+                        if args:
+                            span.set_attribute(
+                                SPANDATA.MESSAGING_DESTINATION_NAME, args[0].name
+                            )
+
                         rv = old_perform_job(self, job, *args, **kwargs)
                 else:
                     transaction = continue_trace(
@@ -115,7 +120,12 @@ def sentry_patched_perform_job(
                     with sentry_sdk.start_transaction(
                         transaction,
                         custom_sampling_context={"rq_job": job},
-                    ):
+                    ) as span:
+                        if args:
+                            span.set_data(
+                                SPANDATA.MESSAGING_DESTINATION_NAME, args[0].name
+                            )
+
                         rv = old_perform_job(self, job, *args, **kwargs)
 
             if self.is_horse:

tests/integrations/rq/test_rq.py

@@ -416,6 +416,7 @@ def test_transaction_no_error(
 
         assert span["attributes"]["sentry.op"] == "queue.task.rq"
         assert span["name"] == "tests.integrations.rq.test_rq.do_trick"
+        assert span["attributes"][SPANDATA.MESSAGING_DESTINATION_NAME] == queue.name
     else:
         events = capture_events()
 
@@ -427,6 +428,10 @@ def test_transaction_no_error(
         assert envelope["type"] == "transaction"
         assert envelope["contexts"]["trace"]["op"] == "queue.task.rq"
         assert envelope["transaction"] == "tests.integrations.rq.test_rq.do_trick"
+        assert (
+            envelope["contexts"]["trace"]["data"][SPANDATA.MESSAGING_DESTINATION_NAME]
+            == queue.name
+        )
         assert envelope["extra"]["rq-job"] == DictionaryContaining(
             {
                 "args": ["Maisey"] if send_default_pii else SENSITIVE_DATA_SUBSTITUTE,