lint

Author: Liudmila Molkova

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

@@ -80,10 +80,7 @@ def build(self) -> Optional[Span]:
         if self._operation:
             self._attributes[SpanAttributes.MESSAGING_OPERATION] = self._operation.value
         else:
-            if self._kind == SpanKind.PRODUCER:
-                self._attributes[SpanAttributes.MESSAGING_DESTINATION_TEMPORARY] = True
-            else:
-                self._attributes[SpanAttributes.MESSAGING_SOURCE_TEMPORARY] = True
+            self._attributes[SpanAttributes.MESSAGING_DESTINATION_TEMPORARY] = True
         span = self._tracer.start_span(
             self._generate_span_name(), kind=self._kind, attributes=self._attributes
         )

instrumentation/opentelemetry-instrumentation-kafka-python/src/opentelemetry/instrumentation/kafka/utils.py

@@ -123,16 +123,11 @@ def set(self, carrier: textmap.CarrierT, key: str, value: str) -> None:
 
 
 def _enrich_span(
-    span,
-    bootstrap_servers: List[str],
-    topic: str,
-    partition: int
+    span, bootstrap_servers: List[str], topic: str, partition: int
 ):
     if span.is_recording():
         span.set_attribute(SpanAttributes.MESSAGING_SYSTEM, "kafka")
-        span.set_attribute(
-            SpanAttributes.MESSAGING_DESTINATION_NAME, topic
-        )
+        span.set_attribute(SpanAttributes.MESSAGING_DESTINATION_NAME, topic)
 
         span.set_attribute(
             SpanAttributes.MESSAGING_KAFKA_DESTINATION_PARTITION, partition

instrumentation/opentelemetry-instrumentation-sqlalchemy/src/opentelemetry/instrumentation/sqlalchemy/engine.py

@@ -314,7 +314,7 @@ def _get_attributes_from_cursor(vendor, cursor, attrs):
         else:
             attrs[
                 SpanAttributes.NET_TRANSPORT
-            ] = NetTransportValues.TCP_IP.value
+            ] = NetTransportValues.IP_TCP.value
 
             attrs[SpanAttributes.NET_PEER_NAME] = info.host
             if info.port: