Address issues reported by flake8.

confluentinc · Dec 16, 2022 · 9a73aa8 · 9a73aa8
1 parent 85a74f5
commit 9a73aa8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/examples/linux_asyncio_consumer.py b/examples/linux_asyncio_consumer.py
@@ -10,6 +10,7 @@
 import pprint
 
 from confluent_kafka import Consumer
+from confluent_kafka import KafkaException
 
 
 assert sys.platform == 'linux', "This example is linux only, cause of eventfd"
@@ -67,7 +68,8 @@ async def poll(self, timeout=0):
             return self._poll_no_timeout()
 
     async def _poll_no_timeout(self):
-        while not (msg := await self._single_poll()): pass
+        while not (msg := await self._single_poll()):
+            pass
         return msg
 
     async def _single_poll(self):