diff --git a/tests/integrations/celery/test_celery.py b/tests/integrations/celery/test_celery.py index 28f2af65e0..197e692461 100644 --- a/tests/integrations/celery/test_celery.py +++ b/tests/integrations/celery/test_celery.py @@ -661,6 +661,20 @@ def task(): ... assert "messaging.destination.name" not in span["data"] +def test_messaging_id(init_celery, capture_events): + celery = init_celery(enable_tracing=True) + events = capture_events() + + @celery.task + def example_task(): ... + + example_task.apply_async() + + (event,) = events + (span,) = event["spans"] + assert "messaging.message.id" in span["data"] + + def test_retry_count_zero(init_celery, capture_events): celery = init_celery(enable_tracing=True) events = capture_events()