Increase default client timeout

Author: Ananto30

docs/api/async-client.md

@@ -10,7 +10,7 @@
 AsyncZeroClient(
     host: str,
     port: int,
-    default_timeout: int = 2000,
+    default_timeout: int = 5000,
     encoder: Type[Encoder] = GenericEncoder,
     protocol: Type[AsyncZeroClientProtocol] = AsyncZMQClient,
     pool_size: int = 50,
@@ -21,7 +21,7 @@ AsyncZeroClient(
 
 - **host** (str): Server hostname or IP address.
 - **port** (int): Server port number.
-- **default_timeout** (int): Default timeout for calls in milliseconds. Default: 2000
+- **default_timeout** (int): Default timeout for calls in milliseconds. Default: 5000
 - **encoder** (Encoder): Message encoder matching server. Default: Msgspec
 - **protocol** (AsyncClientProtocol): Async communication protocol. Default: ZeroMQ
     - `zero.protocols.zeromq.AsyncZeroMQClient` - ZeroMQ (default)

docs/api/client.md

@@ -10,7 +10,7 @@
 ZeroClient(
     host: str,
     port: int,
-    default_timeout: int = 2000,
+    default_timeout: int = 5000,
     encoder: Type[Encoder] = GenericEncoder,
     protocol: Type[ZeroClientProtocol] = ZMQClient,
     pool_size: int = 50,
@@ -21,7 +21,7 @@ ZeroClient(
 
 - **host** (str): Server hostname or IP address.
 - **port** (int): Server port number.
-- **default_timeout** (int): Default timeout for calls in milliseconds. Default: 2000
+- **default_timeout** (int): Default timeout for calls in milliseconds. Default: 5000
 - **encoder** (Encoder): Message encoder matching server. Default: Msgspec
 - **protocol** (ClientProtocol): Communication protocol. Default: ZeroMQ
     - `zero.protocols.zeromq.ZeroMQClient` - ZeroMQ (default)

zero/rpc/client.py

@@ -15,7 +15,7 @@ def __init__(
         self,
         host: str,
         port: int,
-        default_timeout: int = 2000,
+        default_timeout: int = 5000,
         encoder: Type[Encoder] = GenericEncoder,
         protocol: Type[ZeroClientProtocol] = ZMQClient,
         pool_size: int = 50,
@@ -139,7 +139,7 @@ def __init__(
         self,
         host: str,
         port: int,
-        default_timeout: int = 2000,
+        default_timeout: int = 5000,
         encoder: Type[Encoder] = GenericEncoder,
         protocol: Type[AsyncZeroClientProtocol] = AsyncZMQClient,
         pool_size: int = 50,

zero/zeromq_patterns/factory.py

@@ -3,7 +3,7 @@
 from .interfaces import AsyncZeroMQClient, ZeroMQBroker, ZeroMQClient, ZeroMQWorker
 
 
-def get_client(pattern: str, default_timeout: int = 2000) -> ZeroMQClient:
+def get_client(pattern: str, default_timeout: int) -> ZeroMQClient:
     if pattern == "proxy":
         return queue_device.ZeroMQClient(default_timeout)
 

zero/zeromq_patterns/interfaces.py

@@ -6,7 +6,7 @@ class ZeroMQClient(Protocol):  # pragma: no cover
     def __init__(
         self,
         address: str,
-        default_timeout: int = 2000,
+        default_timeout: int = 5000,
     ): ...
 
     def connect(self, address: str) -> None: ...
@@ -21,7 +21,7 @@ class AsyncZeroMQClient(Protocol):  # pragma: no cover
     def __init__(
         self,
         address: str,
-        default_timeout: int = 2000,
+        default_timeout: int = 5000,
     ): ...
 
     async def connect(self, address: str) -> None: ...