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

ref #2951
getsentry · Apr 30, 2024 · cd65142 · cd65142
1 parent d5a29b9
commit cd65142
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/sentry_sdk/integrations/celery/__init__.py b/sentry_sdk/integrations/celery/__init__.py
@@ -336,6 +336,9 @@ def _inner(*args, **kwargs):
             with sentry_sdk.start_span(
                 op=OP.QUEUE_PROCESS, description=task.name
             ) as span:
+                span.set_data(
+                    "messaging.system", task.app.connection().transport.driver_type
+                )
                 _set_messaging_destination_name(task, span)
                 span.set_data("messaging.message.id", task.request.id)
                 span.set_data("messaging.message.retry.count", task.request.retries)