feat(celery): Set task ID on span

Closes #2974
getsentry · May 10, 2024 · 472cb85 · 472cb85
1 parent 6ed9bf7
commit 472cb85
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sentry_sdk/integrations/celery/__init__.py b/sentry_sdk/integrations/celery/__init__.py
@@ -356,6 +356,7 @@ def _inner(*args, **kwargs):
                 op=OP.QUEUE_PROCESS, description=task.name
             ) as span:
                 _set_messaging_destination_name(task, span)
+                span.set_data("messaging.message.id", task.request.id)
                 with capture_internal_exceptions():
                     span.set_data(
                         SPANDATA.MESSAGING_MESSAGE_RETRY_COUNT, task.request.retries