ref(celery): MESSAGNING_DESTINATION_NAME constant

ref #2961
getsentry · May 10, 2024 · c589e6c · c589e6c
1 parent 6a284ed
commit c589e6c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/sentry_sdk/consts.py b/sentry_sdk/consts.py
@@ -233,6 +233,12 @@ class SPANDATA:
     Example: 418
     """
 
+    MESSAGING_DESTINATION_NAME = "messaging.destination.name"
+    """
+    The destination name where the message is being consumed from,
+    e.g. the queue name or topic.
+    """
+
     SERVER_ADDRESS = "server.address"
     """
     Name of the database host.

diff --git a/sentry_sdk/integrations/celery/__init__.py b/sentry_sdk/integrations/celery/__init__.py
@@ -4,7 +4,7 @@
 import sentry_sdk
 from sentry_sdk import isolation_scope
 from sentry_sdk.api import continue_trace
-from sentry_sdk.consts import OP
+from sentry_sdk.consts import OP, SPANDATA
 from sentry_sdk.integrations import Integration, DidNotEnable
 from sentry_sdk.integrations.celery.beat import (
     _patch_beat_apply_entry,
@@ -334,7 +334,7 @@ def _set_messaging_destination_name(task, span):
         if delivery_info.get("exchange") == "" and routing_key is not None:
             # Empty exchange indicates the default exchange, meaning the tasks
             # are sent to the queue with the same name as the routing key.
-            span.set_data("messaging.destination.name", routing_key)
+            span.set_data(SPANDATA.MESSAGING_DESTINATION_NAME, routing_key)
 
 
 def _wrap_task_call(task, f):