feat(celery): Set "messaging.system" on span

ref #2951
getsentry · May 10, 2024 · 60c2d53 · 60c2d53
1 parent 9af5324
commit 60c2d53
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/sentry_sdk/integrations/celery/__init__.py b/sentry_sdk/integrations/celery/__init__.py
@@ -362,6 +362,10 @@ def _inner(*args, **kwargs):
                     span.set_data(
                         SPANDATA.MESSAGING_MESSAGE_RETRY_COUNT, task.request.retries
                     )
+                with capture_internal_exceptions():
+                    span.set_data(
+                        "messaging.system", task.app.connection().transport.driver_type
+                    )
 
                 return f(*args, **kwargs)
         except Exception: