diff --git a/tests/integrations/celery/test_celery.py b/tests/integrations/celery/test_celery.py index 197e692461..cc04c89f74 100644 --- a/tests/integrations/celery/test_celery.py +++ b/tests/integrations/celery/test_celery.py @@ -704,3 +704,21 @@ def task(): ... (event,) = events (span,) = event["spans"] assert span["data"]["messaging.message.retry.count"] == 3 + + +@pytest.mark.parametrize("system", ("redis", "amqp")) +def test_messaging_system(system, init_celery, capture_events): + celery = init_celery(enable_tracing=True) + events = capture_events() + + # Does not need to be a real URL, since we use always eager + celery.conf.broker_url = f"{system}://example.com" + + @celery.task() + def task(): ... + + task.apply_async() + + (event,) = events + (span,) = event["spans"] + assert span["data"]["messaging.system"] == system