fix: change schema

Author: EzzioMoreira

instrumentation/opentelemetry-instrumentation-aio-pika/src/opentelemetry/instrumentation/aio_pika/span_builder.py

@@ -17,7 +17,6 @@
 
 from opentelemetry.instrumentation.utils import is_instrumentation_enabled
 from opentelemetry.semconv._incubating.attributes.messaging_attributes import (
-    MESSAGING_DESTINATION_TEMPORARY,
     MESSAGING_MESSAGE_CONVERSATION_ID,
     MESSAGING_MESSAGE_ID,
     MESSAGING_OPERATION,
@@ -94,7 +93,9 @@ def build(self) -> Optional[Span]:
         if self._operation:
             self._attributes[MESSAGING_OPERATION] = self._operation.value
         else:
-            self._attributes[MESSAGING_DESTINATION_TEMPORARY] = True
+            # TODO: Update this implementation once the semantic conventions for messaging stabilize
+            # See: https://github.com/open-telemetry/semantic-conventions/blob/main/docs/registry/attributes/messaging.md
+            self._attributes[SpanAttributes.MESSAGING_TEMP_DESTINATION] = True
         span = self._tracer.start_span(
             self._generate_span_name(),
             kind=self._kind,

instrumentation/opentelemetry-instrumentation-aio-pika/tests/test_publish_decorator.py

@@ -22,7 +22,6 @@
     PublishDecorator,
 )
 from opentelemetry.semconv._incubating.attributes.messaging_attributes import (
-    MESSAGING_DESTINATION_TEMPORARY,
     MESSAGING_MESSAGE_CONVERSATION_ID,
     MESSAGING_MESSAGE_ID,
     MESSAGING_SYSTEM,
@@ -60,7 +59,7 @@ class TestInstrumentedExchangeAioRmq7(TestCase):
         NET_PEER_PORT: SERVER_PORT,
         MESSAGING_MESSAGE_ID: MESSAGE_ID,
         MESSAGING_MESSAGE_CONVERSATION_ID: CORRELATION_ID,
-        MESSAGING_DESTINATION_TEMPORARY: True,
+        SpanAttributes.MESSAGING_TEMP_DESTINATION: True,
     }
 
     def setUp(self):
@@ -139,7 +138,7 @@ class TestInstrumentedExchangeAioRmq8(TestCase):
         NET_PEER_PORT: SERVER_PORT,
         MESSAGING_MESSAGE_ID: MESSAGE_ID,
         MESSAGING_MESSAGE_CONVERSATION_ID: CORRELATION_ID,
-        MESSAGING_DESTINATION_TEMPORARY: True,
+        SpanAttributes.MESSAGING_TEMP_DESTINATION: True,
     }
 
     def setUp(self):