ref(celery): MESSAGING.SYSTEM SPANDATA constant

ref #2951
getsentry · May 10, 2024 · 6c84461 · 6c84461
1 parent 60c2d53
commit 6c84461
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/sentry_sdk/consts.py b/sentry_sdk/consts.py
@@ -249,6 +249,11 @@ class SPANDATA:
     Number of retries/attempts to process a message.
     """
 
+    MESSAGING_SYSTEM = "messaging.system"
+    """
+    The messaging system's name, e.g. `kafka`, `aws_sqs`
+    """
+
     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
@@ -364,7 +364,8 @@ def _inner(*args, **kwargs):
                     )
                 with capture_internal_exceptions():
                     span.set_data(
-                        "messaging.system", task.app.connection().transport.driver_type
+                        SPANDATA.MESSAGING_SYSTEM,
+                        task.app.connection().transport.driver_type,
                     )
 
                 return f(*args, **kwargs)