pika: Fix messaging.destination attribute

baodrate · baodrate · commit a200c34a6a14 · 2026-04-08T11:12:40.000-05:00
diff --git a/instrumentation/opentelemetry-instrumentation-pika/src/opentelemetry/instrumentation/pika/utils.py b/instrumentation/opentelemetry-instrumentation-pika/src/opentelemetry/instrumentation/pika/utils.py
@@ -157,7 +157,7 @@ def _get_span(
         kind=span_kind,
     )
     if span.is_recording():
-        _enrich_span(span, channel, properties, task_name, operation)
+        _enrich_span(span, channel, properties, destination, operation)
     return span
 
 

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ def _get_span(`
`157`	`157`	`kind=span_kind,`
`158`	`158`	`)`
`159`	`159`	`if span.is_recording():`
`160`		`- _enrich_span(span, channel, properties, task_name, operation)`
	`160`	`+ _enrich_span(span, channel, properties, destination, operation)`
`161`	`161`	`return span`
`162`	`162`
`163`	`163`