refactor: little type changes

airtai · Nov 5, 2024 · 2a4c51d · 2a4c51d
1 parent f54e5ee
commit 2a4c51d
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/faststream/_internal/fastapi/router.py b/faststream/_internal/fastapi/router.py
@@ -327,6 +327,7 @@ async def start_broker_lifespan(
                 else:
                     warnings.warn(
                         "Specifying 'lifespan_context' manually is no longer necessary with FastAPI >= 0.112.2.",
+                        category=RuntimeWarning,
                         stacklevel=2,
                     )
 

diff --git a/faststream/confluent/broker/broker.py b/faststream/confluent/broker/broker.py
@@ -524,7 +524,7 @@ async def publish(  # type: ignore[override]
             correlation_id=correlation_id or gen_cor_id(),
             _publish_type=PublishType.Publish,
         )
-        return await super()._basic_publish(cmd, producer=self._producer)
+        await super()._basic_publish(cmd, producer=self._producer)
 
     @override
     async def request(  # type: ignore[override]

diff --git a/faststream/kafka/broker/broker.py b/faststream/kafka/broker/broker.py
@@ -744,7 +744,7 @@ async def publish(  # type: ignore[override]
             correlation_id=correlation_id or gen_cor_id(),
             _publish_type=PublishType.Publish,
         )
-        return await super()._basic_publish(cmd, producer=self._producer)
+        await super()._basic_publish(cmd, producer=self._producer)
 
     @override
     async def request(  # type: ignore[override]