diff --git a/sentry_sdk/integrations/celery/__init__.py b/sentry_sdk/integrations/celery/__init__.py index ea217cf6a6..0d9ddd719d 100644 --- a/sentry_sdk/integrations/celery/__init__.py +++ b/sentry_sdk/integrations/celery/__init__.py @@ -337,6 +337,7 @@ def _inner(*args, **kwargs): op=OP.QUEUE_TASK_CELERY, description=task.name ) as span: _set_messaging_destination_name(task, span) + span.set_data("messaging.message.retry.count", task.request.retries) return f(*args, **kwargs) except Exception: exc_info = sys.exc_info()