Fixed according to flake8

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

@@ -13,7 +13,7 @@
 # limitations under the License.
 from typing import Any, Callable, Optional
 
-from aio_pika import Channel, Queue, RobustQueue, connect
+from aio_pika import Queue, RobustQueue
 from aio_pika.abc import AbstractIncomingMessage
 from aio_pika.queue import ConsumerTag
 

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

@@ -34,34 +34,34 @@ def __init__(self):
         self._operation: MessagingOperationValues = None
         self._kind: SpanKind = None
         self._destination: str = None
-    
+
     def set_as_producer(self):
         self._kind = SpanKind.PRODUCER
 
     def set_as_consumer(self):
         self._kind = SpanKind.CONSUMER
-    
+
     def set_operation(self, operation: MessagingOperationValues):
         self._operation = operation
-    
+
     def set_destination(self, destination: str):
         self._destination = destination
         self._attributes[SpanAttributes.MESSAGING_DESTINATION] = destination
-    
+
     def set_channel(self, channel: AbstractChannel):
         url = channel.connection.connection.url
         self._attributes.update({
             SpanAttributes.NET_PEER_NAME: url.host,
             SpanAttributes.NET_PEER_PORT: url.port
         })
-    
+
     def set_message(self, message: AbstractMessage):
         properties = message.properties
         if properties.message_id:
             self._attributes[SpanAttributes.MESSAGING_MESSAGE_ID] = properties.message_id
         if properties.correlation_id:
             self._attributes[SpanAttributes.MESSAGING_CONVERSATION_ID] = properties.correlation_id
-    
+
     def build(self) -> Optional[Span]:
         if context.get_value('suppress_instrumentation') or context.get_value(context._SUPPRESS_INSTRUMENTATION_KEY):
             return None
@@ -78,7 +78,7 @@ def build(self) -> Optional[Span]:
         else:
             span.set_attribute(SpanAttributes.MESSAGING_TEMP_DESTINATION, True)
         return span
-    
+
     def _generate_span_name(self) -> str:
         operation_value = self._operation.value if self._operation else 'send'
         return f'{self._destination} {operation_value}'

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

@@ -12,19 +12,17 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 import asyncio
-from argparse import Namespace
 from typing import Type
 from unittest import TestCase, mock
 
 from aio_pika import Exchange
-from yarl import URL
 
 from opentelemetry.instrumentation.aio_pika.instrumented_exchange import (
     InstrumentedExchange,
     RobustInstrumentedExchange,
 )
 from opentelemetry.semconv.trace import SpanAttributes
-from opentelemetry.trace import NonRecordingSpan, Span
+from opentelemetry.trace import NonRecordingSpan
 
 from .consts import (
     CHANNEL,

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

@@ -12,19 +12,17 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 import asyncio
-from argparse import Namespace
 from typing import Type
 from unittest import TestCase, mock
 
 from aio_pika import Queue
-from yarl import URL
 
 from opentelemetry.instrumentation.aio_pika.instrumented_queue import (
     InstrumentedQueue,
     RobustInstrumentedQueue,
 )
 from opentelemetry.semconv.trace import SpanAttributes
-from opentelemetry.trace import NonRecordingSpan, Span
+from opentelemetry.trace import NonRecordingSpan
 
 from .consts import (
     CHANNEL,
@@ -35,7 +33,6 @@
     MESSAGE_ID,
     MESSAGING_SYSTEM,
     QUEUE_NAME,
-    ROUTING_KEY,
     SERVER_HOST,
     SERVER_PORT,
 )

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

@@ -24,13 +24,13 @@ def test_build(self):
         builder.set_destination('destination')
         span = builder.build()
         self.assertTrue(isinstance(span, Span))
-    
+
     def test_no_destination(self):
         builder = SpanBuilder()
         builder.set_as_consumer()
         with self.assertRaises(AssertionError):
             builder.build()
-    
+
     def test_no_kind(self):
         builder = SpanBuilder()
         builder.set_destination('destination')