Fix: lint

airtai · Dec 10, 2024 · 6c67fd0 · 6c67fd0
1 parent 4ba1910
commit 6c67fd0
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/faststream/_internal/broker/router.py b/faststream/_internal/broker/router.py
@@ -84,7 +84,7 @@ def __init__(
             decoder=decoder,
             include_in_schema=include_in_schema,
             state=EmptyBrokerState("You should include router to any broker."),
-            routers=routers
+            routers=routers,
         )
 
         for h in handlers:

diff --git a/faststream/confluent/broker/broker.py b/faststream/confluent/broker/broker.py
@@ -454,7 +454,7 @@ async def _connect(  # type: ignore[override]
             **kwargs,
             client_id=client_id,
             config=self.config,
-            logger=self._state.get().logger_state
+            logger=self._state.get().logger_state,
         )
 
         self._producer.connect(native_producer)

diff --git a/tests/brokers/kafka/test_consume.py b/tests/brokers/kafka/test_consume.py
@@ -399,7 +399,9 @@ async def handler(msg):
 
             await asyncio.wait(
                 (
-                    asyncio.create_task(br._producer._producer.producer.send(queue, key=b"")),
+                    asyncio.create_task(
+                        br._producer._producer.producer.send(queue, key=b"")
+                    ),
                     asyncio.create_task(event.wait()),
                 ),
                 timeout=3,
@@ -426,7 +428,9 @@ async def handler(msg):
 
             await asyncio.wait(
                 (
-                    asyncio.create_task(br._producer._producer.producer.send(queue, key=b"")),
+                    asyncio.create_task(
+                        br._producer._producer.producer.send(queue, key=b"")
+                    ),
                     asyncio.create_task(event.wait()),
                 ),
                 timeout=3,