Skip to content

Commit

Permalink
feat(celery): Set "messaging.system" on span
Browse files Browse the repository at this point in the history
ref #2951
  • Loading branch information
szokeasaurusrex committed May 3, 2024
1 parent d5a29b9 commit 0e19e51
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions sentry_sdk/integrations/celery/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -339,6 +339,11 @@ def _inner(*args, **kwargs):
_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)
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()
Expand Down

0 comments on commit 0e19e51

Please sign in to comment.