Skip to content

fix: lower default streaming read timeout to 20s [AIR-1092] #597

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Cubestormer-IV wants to merge 2 commits into
base: main
Choose a base branch
from
Open

fix: lower default streaming read timeout to 20s [AIR-1092] #597

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
3c50848
fix: lower default streaming read timeout to 20s [AIR-1092]
Jul 23, 2026
9bac14c
feat: add stream_timeout_ms to SDKConfiguration and Mistral.__init__ …
Jul 24, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions src/mistralai/client/agents.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -462,11 +462,13 @@ def stream(
"""
base_url = None
url_variables = None
if timeout_ms is None:
timeout_ms = self.sdk_configuration.stream_timeout_ms
if timeout_ms is None:
timeout_ms = self.sdk_configuration.timeout_ms

if timeout_ms is None:
timeout_ms = 300000
timeout_ms = 20000

if server_url is not None:
base_url = server_url
Expand Down Expand Up @@ -656,11 +658,13 @@ async def stream_async(
"""
base_url = None
url_variables = None
if timeout_ms is None:
timeout_ms = self.sdk_configuration.stream_timeout_ms
if timeout_ms is None:
timeout_ms = self.sdk_configuration.timeout_ms

if timeout_ms is None:
timeout_ms = 300000
timeout_ms = 20000

if server_url is not None:
base_url = server_url
Expand Down
8 changes: 6 additions & 2 deletions src/mistralai/client/chat.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -571,11 +571,13 @@ def stream(
"""
base_url = None
url_variables = None
if timeout_ms is None:
timeout_ms = self.sdk_configuration.stream_timeout_ms
if timeout_ms is None:
timeout_ms = self.sdk_configuration.timeout_ms

if timeout_ms is None:
timeout_ms = 300000
timeout_ms = 20000

if server_url is not None:
base_url = server_url
Expand Down Expand Up @@ -774,11 +776,13 @@ async def stream_async(
"""
base_url = None
url_variables = None
if timeout_ms is None:
timeout_ms = self.sdk_configuration.stream_timeout_ms
if timeout_ms is None:
timeout_ms = self.sdk_configuration.timeout_ms

if timeout_ms is None:
timeout_ms = 300000
timeout_ms = 20000

if server_url is not None:
base_url = server_url
Expand Down
8 changes: 6 additions & 2 deletions src/mistralai/client/fim.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -329,11 +329,13 @@ def stream(
"""
base_url = None
url_variables = None
if timeout_ms is None:
timeout_ms = self.sdk_configuration.stream_timeout_ms
if timeout_ms is None:
timeout_ms = self.sdk_configuration.timeout_ms

if timeout_ms is None:
timeout_ms = 300000
timeout_ms = 20000

if server_url is not None:
base_url = server_url
Expand Down Expand Up @@ -471,11 +473,13 @@ async def stream_async(
"""
base_url = None
url_variables = None
if timeout_ms is None:
timeout_ms = self.sdk_configuration.stream_timeout_ms
if timeout_ms is None:
timeout_ms = self.sdk_configuration.timeout_ms

if timeout_ms is None:
timeout_ms = 300000
timeout_ms = 20000

if server_url is not None:
base_url = server_url
Expand Down
3 changes: 3 additions & 0 deletions src/mistralai/client/sdk.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,7 @@ def __init__(
async_client: Optional[AsyncHttpClient] = None,
retry_config: OptionalNullable[RetryConfig] = UNSET,
timeout_ms: Optional[int] = None,
stream_timeout_ms: Optional[int] = None,
debug_logger: Optional[Logger] = None,
) -> None:
r"""Instantiates the SDK configuring it with the provided parameters.
Expand All @@ -93,6 +94,7 @@ def __init__(
:param async_client: The Async HTTP client to use for all asynchronous methods
:param retry_config: The retry configuration to use for all supported methods
:param timeout_ms: Optional request timeout applied to each operation in milliseconds
:param stream_timeout_ms: Optional idle-read timeout for SSE streaming operations in milliseconds (default 20 000 ms). Overrides timeout_ms for streaming calls only.
"""
client_supplied = True
if client is None:
Expand Down Expand Up @@ -140,6 +142,7 @@ def __init__(
server=server,
retry_config=retry_config,
timeout_ms=timeout_ms,
stream_timeout_ms=stream_timeout_ms,
debug_logger=debug_logger,
),
parent_ref=self,
Expand Down
1 change: 1 addition & 0 deletions src/mistralai/client/sdkconfiguration.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@ class SDKConfiguration:
user_agent: str = __user_agent__
retry_config: OptionalNullable[RetryConfig] = Field(default_factory=lambda: UNSET)
timeout_ms: Optional[int] = None
stream_timeout_ms: Optional[int] = None

def get_server_details(self) -> Tuple[str, Dict[str, str]]:
if self.server_url is not None and self.server_url:
Expand Down
Loading