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

ref #2951
getsentry · May 7, 2024 · 2b51425 · 2b51425
1 parent df18b49
commit 2b51425
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/sentry_sdk/integrations/celery/__init__.py b/sentry_sdk/integrations/celery/__init__.py
@@ -341,6 +341,11 @@ def _inner(*args, **kwargs):
                     span.set_data("messaging.message.id", task.request.id)
                 with capture_internal_exceptions():
                     span.set_data("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:
             exc_info = sys.exc_info()