From d5a29b98c0f19e161b11063a6e4957d51a8db6cc Mon Sep 17 00:00:00 2001 From: Daniel Szoke Date: Thu, 25 Apr 2024 12:06:30 +0200 Subject: [PATCH] test(celery): Test that message ID set on span --- tests/integrations/celery/test_celery.py | 14 ++++++++++++++ 1 file changed, 14 insertions(+) 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()