diff --git a/instrumentation/opentelemetry-instrumentation-remoulade/src/opentelemetry/instrumentation/remoulade/__init__.py b/instrumentation/opentelemetry-instrumentation-remoulade/src/opentelemetry/instrumentation/remoulade/__init__.py index 8463ffe05d..28a41b6a6c 100644 --- a/instrumentation/opentelemetry-instrumentation-remoulade/src/opentelemetry/instrumentation/remoulade/__init__.py +++ b/instrumentation/opentelemetry-instrumentation-remoulade/src/opentelemetry/instrumentation/remoulade/__init__.py @@ -55,7 +55,7 @@ def multiply(x, y): from opentelemetry.instrumentation.remoulade.package import _instruments from opentelemetry.instrumentation.remoulade.version import __version__ from opentelemetry.propagate import extract, inject -from opentelemetry.semconv.trace import SpanAttributes +from opentelemetry.semconv._incubating.attributes import messaging_attributes _REMOULADE_MESSAGE_TAG_KEY = "remoulade.action" _REMOULADE_MESSAGE_SEND = "send" @@ -112,7 +112,7 @@ def after_process_message( { _REMOULADE_MESSAGE_TAG_KEY: _REMOULADE_MESSAGE_RUN, _REMOULADE_MESSAGE_NAME_KEY: message.actor_name, - SpanAttributes.MESSAGING_MESSAGE_ID: message.message_id, + messaging_attributes.MESSAGING_MESSAGE_ID: message.message_id, } ) @@ -137,7 +137,7 @@ def before_enqueue(self, _broker, message, delay): { _REMOULADE_MESSAGE_TAG_KEY: _REMOULADE_MESSAGE_SEND, _REMOULADE_MESSAGE_NAME_KEY: message.actor_name, - SpanAttributes.MESSAGING_MESSAGE_ID: message.message_id, + messaging_attributes.MESSAGING_MESSAGE_ID: message.message_id, } )