diff --git a/src/mcp/client/sse.py b/src/mcp/client/sse.py index 4f6241a7..2fd9729f 100644 --- a/src/mcp/client/sse.py +++ b/src/mcp/client/sse.py @@ -61,7 +61,7 @@ async def sse_reader( logger.debug(f"Received SSE event: {sse.event}") match sse.event: case "endpoint": - endpoint_url = urljoin(url, sse.data) + endpoint_url = url.rstrip("/sse") + sse.data logger.info( f"Received endpoint URL: {endpoint_url}" )