modelcontextprotocol/python-sdk
Watch
1
0
Fork
You've already forked python-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

RFC: Lower log levels used for connections (#821)

Browse source
This commit is contained in:
Nick Cooper 2025-05-27 18:11:08 -04:00 • committed by GitHub
commit 532b1176f9
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/mcp/client/sse.py
View file

@ -53,7 +53,7 @@ async def sse_client(
async with anyio.create_task_group() as tg: async with anyio.create_task_group() as tg:
try: try:
logger.info(f"Connecting to SSE endpoint: {remove_request_params(url)}") logger.debug(f"Connecting to SSE endpoint: {remove_request_params(url)}")
async with httpx_client_factory(headers=headers, auth=auth) as client: async with httpx_client_factory(headers=headers, auth=auth) as client:
async with aconnect_sse( async with aconnect_sse(
client, client,
@ -73,7 +73,7 @@ async def sse_client(
match sse.event: match sse.event:
case "endpoint": case "endpoint":
endpoint_url = urljoin(url, sse.data) endpoint_url = urljoin(url, sse.data)
logger.info( logger.debug(
f"Received endpoint URL: {endpoint_url}" f"Received endpoint URL: {endpoint_url}"
) )
@ -146,7 +146,7 @@ async def sse_client(
await write_stream.aclose() await write_stream.aclose()
endpoint_url = await tg.start(sse_reader) endpoint_url = await tg.start(sse_reader)
logger.info( logger.debug(
f"Starting post writer with endpoint URL: {endpoint_url}" f"Starting post writer with endpoint URL: {endpoint_url}"
) )
tg.start_soon(post_writer, endpoint_url) tg.start_soon(post_writer, endpoint_url)

2
src/mcp/client/streamable_http.py
View file

@ -463,7 +463,7 @@ async def streamablehttp_client(
async with anyio.create_task_group() as tg: async with anyio.create_task_group() as tg:
try: try:
logger.info(f"Connecting to StreamableHTTP endpoint: {url}") logger.debug(f"Connecting to StreamableHTTP endpoint: {url}")
async with httpx_client_factory( async with httpx_client_factory(
headers=transport.request_headers, headers=transport.request_headers,