Skip to content

Commit dd8ebdd

Browse files
author
mriamah
committed
Add back MESSAGING_DESTINATION_KIND use in celery instrumentation for backward compatibility
1 parent 17a9f5c commit dd8ebdd

File tree

1 file changed

+1
-0
lines changed
  • instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery

1 file changed

+1
-0
lines changed

instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery/utils.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -137,6 +137,7 @@ def set_attributes_from_context(
137137

138138
# according to https://docs.celeryproject.org/en/stable/userguide/routing.html#exchange-types
139139
elif key == "declare":
140+
attribute_name = SpanAttributes.MESSAGING_DESTINATION_KIND
140141
for declare in value:
141142
if declare.exchange.type == "direct":
142143
value = "queue"

0 commit comments

Comments
 (0)