fix: AsyncConfluentFastProducer type hints.

airtai · Jan 5, 2025 · 6ecdf73 · 6ecdf73
1 parent 802df07
commit 6ecdf73
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/faststream/confluent/publisher/producer.py b/faststream/confluent/publisher/producer.py
@@ -45,7 +45,7 @@ async def disconnect(self) -> None:
     def __bool__(self) -> bool:
         return bool(self._producer)
 
-    async def ping(self, timeout: float) -> None:
+    async def ping(self, timeout: float) -> bool:
         return await self._producer.ping(timeout=timeout)
 
     @override
@@ -71,7 +71,8 @@ async def publish(  # type: ignore[override]
             no_confirm=cmd.no_confirm,
         )
 
-    async def publish_batch(
+    @override
+    async def publish_batch(  # type: ignore[override]
         self,
         cmd: "KafkaPublishCommand",
     ) -> None:
@@ -106,7 +107,7 @@ async def publish_batch(
         )
 
     @override
-    async def request(
+    async def request(  # type: ignore[override]
         self,
         cmd: "KafkaPublishCommand",
     ) -> Any: