From 7bd9706d55b403bc3f05d8a5184225b9dac4840a Mon Sep 17 00:00:00 2001 From: Nikita Pastukhov Date: Mon, 16 Sep 2024 19:00:09 +0300 Subject: [PATCH 1/2] fix (#1792): make RMQ publisher.publish reply_to optional --- faststream/rabbit/publisher/usecase.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faststream/rabbit/publisher/usecase.py b/faststream/rabbit/publisher/usecase.py index c3306c78d2..2971913772 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[ From efff694d75e53a2b3cf07237ffcc850d7194637d Mon Sep 17 00:00:00 2001 From: Nikita Pastukhov Date: Mon, 16 Sep 2024 19:16:55 +0300 Subject: [PATCH 2/2] lint: fix mypy --- faststream/rabbit/publisher/usecase.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faststream/rabbit/publisher/usecase.py b/faststream/rabbit/publisher/usecase.py index 2971913772..f03b3b4a72 100644 --- a/faststream/rabbit/publisher/usecase.py +++ b/faststream/rabbit/publisher/usecase.py @@ -181,7 +181,7 @@ def __hash__(self) -> int: ) @override - async def publish( # type: ignore[override] + async def publish( self, message: "AioPikaSendableMessage", queue: Annotated[