Add default timeout

Author: WiZeYAR

src/asyncapi_python/kernel/endpoint/abc.py

@@ -14,6 +14,9 @@ class EndpointParams(TypedDict, total=False):
     """Optional parameters for endpoint configuration"""
 
     service_name: str  # Service name for generating app_id
+    default_rpc_timeout: (
+        float | None
+    )  # Default timeout in seconds for RPC client requests (default: 180.0), or None to disable
     disable_handler_validation: bool  # Opt-out of handler enforcement for testing
 
 

src/asyncapi_python/kernel/endpoint/rpc_client.py

@@ -2,7 +2,7 @@
 from typing import Generic
 from uuid import uuid4
 
-from typing_extensions import Unpack
+from typing_extensions import NotRequired, Unpack
 
 from asyncapi_python.kernel.wire import Producer
 
@@ -21,6 +21,13 @@ class RpcClient(AbstractEndpoint, Send[T_Input, T_Output], Generic[T_Input, T_Ou
     a single reply consumer and background task for efficiency.
     """
 
+    class RouterInputs(Send.RouterInputs):
+        """Router inputs for RPC client, extending Send.RouterInputs with timeout"""
+
+        timeout: NotRequired[
+            float | None
+        ]  # Timeout in seconds for this RPC request, or None to disable timeout
+
     def __init__(self, **kwargs: Unpack[AbstractEndpoint.Inputs]):
         super().__init__(**kwargs)
         # Instance-specific state
@@ -76,18 +83,17 @@ async def stop(self) -> None:
         if remaining_count == 0:
             await global_reply_handler.cleanup_if_last_instance()
 
-    async def __call__(
-        self,
-        payload: T_Input,
-        /,
-        timeout: float = 30.0,
-        **kwargs: Unpack[Send.RouterInputs],
+    async def __call__(  # type: ignore[override]
+        self, payload: T_Input, /, **kwargs: Unpack[RouterInputs]
     ) -> T_Output:
         """Send an RPC request and wait for response using global reply handling
 
         Args:
             payload: The request payload to send
-            timeout: Maximum time to wait for response (default 30 seconds)
+            **kwargs: Router inputs including optional timeout:
+                     - Not provided: uses default_rpc_timeout from endpoint_params (default: 180.0)
+                     - float: uses the specified timeout in seconds
+                     - None: disables timeout (waits indefinitely)
 
         Returns:
             The response payload
@@ -99,6 +105,14 @@ async def __call__(
         if not self._producer:
             raise UninitializedError()
 
+        # Determine timeout: use provided value, or fall back to endpoint_params default
+        if "timeout" in kwargs:
+            # Explicitly provided (could be float or None)
+            timeout = kwargs["timeout"]
+        else:
+            # Not provided, use default from endpoint_params
+            timeout = self._endpoint_params.get("default_rpc_timeout", 180.0)
+
         # Generate correlation ID for this request
         correlation_id: str = str(uuid4())
 

src/asyncapi_python/kernel/endpoint/rpc_reply_handler.py

@@ -5,9 +5,10 @@
 from typing import Any
 
 from asyncapi_python.kernel.document import Channel, Operation
-from asyncapi_python.kernel.wire import AbstractWireFactory, Consumer, EndpointParams
+from asyncapi_python.kernel.wire import AbstractWireFactory, Consumer
 
 from ..typing import IncomingMessage
+from .abc import EndpointParams
 
 
 class GlobalRpcReplyHandler: