8000
We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 20dc0fb commit 0bcecffCopy full SHA for 0bcecff
src/mcp/client/sse.py
@@ -54,12 +54,13 @@ async def sse_client(
54
async with anyio.create_task_group() as tg:
55
try:
56
logger.debug(f"Connecting to SSE endpoint: {remove_request_params(url)}")
57
- async with httpx_client_factory(headers=headers, auth=auth) as client:
+ async with httpx_client_factory(
58
+ headers=headers, auth=auth, timeout=httpx.Timeout(timeout, read=sse_read_timeout)
59
+ ) as client:
60
async with aconnect_sse(
61
client,
62
"GET",
63
url,
- timeout=httpx.Timeout(timeout, read=sse_read_timeout),
64
) as event_source:
65
event_source.response.raise_for_status()
66
logger.debug("SSE connection established")
0 commit comments