Add back attribute MESSAGING_DESTINATION_KIND to celery instrumentation test

mriamah · mriamah · commit cba8dfa543c9 · 2025-11-01T12:21:19.000+01:00
diff --git a/instrumentation/opentelemetry-instrumentation-celery/tests/test_tasks.py b/instrumentation/opentelemetry-instrumentation-celery/tests/test_tasks.py
@@ -90,6 +90,7 @@ def test_task(self):
             {
                 "celery.action": "apply_async",
                 "celery.task_name": "tests.celery_test_tasks.task_add",
+                SpanAttributes.MESSAGING_DESTINATION_KIND: "queue",
                 SpanAttributes.MESSAGING_DESTINATION: "celery",
             },
         )
@@ -154,6 +155,7 @@ def test_task_raises(self):
             {
                 "celery.action": "apply_async",
                 "celery.task_name": "tests.celery_test_tasks.task_raises",
+                SpanAttributes.MESSAGING_DESTINATION_KIND: "queue",
                 SpanAttributes.MESSAGING_DESTINATION: "celery",
             },
         )

Original file line number	Diff line number	Diff line change
`@@ -90,6 +90,7 @@ def test_task(self):`
`90`	`90`	`{`
`91`	`91`	`"celery.action": "apply_async",`
`92`	`92`	`"celery.task_name": "tests.celery_test_tasks.task_add",`
	`93`	`+ SpanAttributes.MESSAGING_DESTINATION_KIND: "queue",`
`93`	`94`	`SpanAttributes.MESSAGING_DESTINATION: "celery",`
`94`	`95`	`},`
`95`	`96`	`)`
`@@ -154,6 +155,7 @@ def test_task_raises(self):`
`154`	`155`	`{`
`155`	`156`	`"celery.action": "apply_async",`
`156`	`157`	`"celery.task_name": "tests.celery_test_tasks.task_raises",`
	`158`	`+ SpanAttributes.MESSAGING_DESTINATION_KIND: "queue",`
`157`	`159`	`SpanAttributes.MESSAGING_DESTINATION: "celery",`
`158`	`160`	`},`
`159`	`161`	`)`