Fix: run lint.sh

Author: Daniil Dumchenko

faststream/confluent/broker/broker.py

@@ -528,7 +528,4 @@ async def publish_batch(
     @override
     async def ping(self, timeout: Optional[float]) -> bool:
         with move_on_after(timeout) as cancel_scope:
-            return not (
-                cancel_scope.cancel_called or self._producer is None
-            )
-
+            return not (cancel_scope.cancel_called or self._producer is None)

faststream/kafka/broker/broker.py

@@ -812,7 +812,7 @@ async def publish_batch(
     async def ping(self, timeout: Optional[float]) -> bool:
         with move_on_after(timeout) as cancel_scope:
             return not (
-                cancel_scope.cancel_called or
-                self._producer is None or
-                self._producer._producer._closed
+                cancel_scope.cancel_called
+                or self._producer is None
+                or self._producer._producer._closed
             )