diff --git a/faststream/rabbit/publisher/usecase.py b/faststream/rabbit/publisher/usecase.py index c3306c78d2..f03b3b4a72 100644 --- a/faststream/rabbit/publisher/usecase.py +++ b/faststream/rabbit/publisher/usecase.py @@ -97,7 +97,7 @@ class RequestPublishKwargs(TypedDict, total=False): ] -class PublishKwargs(RequestPublishKwargs): +class PublishKwargs(RequestPublishKwargs, total=False): """Typed dict to annotate RabbitMQ publishers.""" reply_to: Annotated[ @@ -181,7 +181,7 @@ def __hash__(self) -> int: ) @override - async def publish( # type: ignore[override] + async def publish( self, message: "AioPikaSendableMessage", queue: Annotated[