fix flake8

Author: rohitsanj

tests/common/_async/consumer.py

@@ -20,7 +20,7 @@
 if sys.version_info >= (3, 11):
     from asyncio import timeout
 else:
-    from async_timeout import timeout
+    from async_timeout import timeout  # noqa: F401
 
 from confluent_kafka.cimpl import Consumer
 from confluent_kafka.error import ConsumeError, KeyDeserializationError, ValueDeserializationError
@@ -48,9 +48,9 @@ def __aiter__(self):
     async def __anext__(self):
         return await self.poll(None)
 
-    async def poll(self, timeout: int = -1):
-        timeout = None if timeout == -1 else timeout
-        async with asyncio.timeout(timeout):
+    async def poll(self, poll_timeout: int = -1):
+        poll_timeout = None if poll_timeout == -1 else poll_timeout
+        async with asyncio.timeout(poll_timeout):
             while True:
                 # Zero timeout here is what makes it non-blocking
                 msg = super().poll(0)
@@ -67,8 +67,8 @@ def __init__(self, conf):
         self._value_deserializer = conf_copy.pop('value.deserializer', None)
         super().__init__(conf_copy)
 
-    async def poll(self, timeout=-1):
-        msg = await super().poll(timeout)
+    async def poll(self, poll_timeout=-1):
+        msg = await super().poll(poll_timeout)
 
         if msg is None:
             return None
@@ -96,7 +96,7 @@ async def poll(self, timeout=-1):
         msg.set_value(value)
         return msg
 
-    def consume(self, num_messages=1, timeout=-1):
+    def consume(self, num_messages=1, consume_timeout=-1):
         """
         :py:func:`Consumer.consume` not implemented, use
         :py:func:`DeserializingConsumer.poll` instead

tests/integration/integration_test.py

@@ -213,6 +213,7 @@ def verify_producer():
 # Global variable to track garbage collection of suppressed on_delivery callbacks
 DrOnlyTestSuccess_gced = 0
 
+
 @pytest.mark.skip(reason="This test must be run as a standalone script")
 def test_producer_dr_only_error():
     """