From e3d378da408eaf77830811f4fad73a9331091800 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 9ac3d2aa7d..646256ffd7 100644 --- a/tests/integrations/celery/test_celery.py +++ b/tests/integrations/celery/test_celery.py @@ -616,3 +616,17 @@ def example_task(): pytest.fail("Calling `apply_async` without arguments raised a TypeError") assert result.get() == "success" + + +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"]