From 90559a7d9d3d4cba8a424898b957a9a5373a0dc7 Mon Sep 17 00:00:00 2001 From: farmer Date: Wed, 14 Jan 2026 16:31:46 +0800 Subject: [PATCH 1/2] fix subscribe docstring typo Signed-off-by: farmer --- dapr/clients/grpc/client.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/dapr/clients/grpc/client.py b/dapr/clients/grpc/client.py index 8e56c188..b4f01128 100644 --- a/dapr/clients/grpc/client.py +++ b/dapr/clients/grpc/client.py @@ -500,9 +500,6 @@ def subscribe( topic (str): The name of the topic. metadata (Optional[MetadataTuple]): Additional metadata for the subscription. dead_letter_topic (Optional[str]): Name of the dead-letter topic. - timeout (Optional[int]): The time in seconds to wait for a message before returning None - If not set, the `next_message` method will block indefinitely - until a message is received. Returns: Subscription: The Subscription object managing the stream. From 2224378da564f51ed1dbe116911ea81bf2921498 Mon Sep 17 00:00:00 2001 From: farmer Date: Wed, 14 Jan 2026 16:53:22 +0800 Subject: [PATCH 2/2] fix subscribe docstring typo Signed-off-by: farmer --- dapr/clients/grpc/client.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/dapr/clients/grpc/client.py b/dapr/clients/grpc/client.py index b4f01128..ccf0ed72 100644 --- a/dapr/clients/grpc/client.py +++ b/dapr/clients/grpc/client.py @@ -525,9 +525,6 @@ def subscribe_with_handler( handler_fn (Callable[..., TopicEventResponse]): The function to call when a message is received. metadata (Optional[MetadataTuple]): Additional metadata for the subscription. dead_letter_topic (Optional[str]): Name of the dead-letter topic. - timeout (Optional[int]): The time in seconds to wait for a message before returning None - If not set, the `next_message` method will block indefinitely - until a message is received. """ subscription = self.subscribe(pubsub_name, topic, metadata, dead_letter_topic)