From 2b5142568b455ba8b15ee6af89405b2fe437dd56 Mon Sep 17 00:00:00 2001 From: Daniel Szoke Date: Fri, 26 Apr 2024 13:25:40 +0200 Subject: [PATCH] feat(celery): Set "messaging.system" on span ref #2951 --- sentry_sdk/integrations/celery/__init__.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/sentry_sdk/integrations/celery/__init__.py b/sentry_sdk/integrations/celery/__init__.py index a3b00a90c7..79ea3925f0 100644 --- 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()