MCP server in the HTTP Streamable mode broken

Starting from v1.12.0 (checked with v1.12.0 and v1.12.1) any request to the MCP server in the HTTP Streamable mode produces an error:

INFO:     127.0.0.1:32926 - "POST /mcp/ HTTP/1.1" 307 Temporary Redirect
[07/23/25 16:34:18] INFO     Processing request of type ListToolsRequest                                        server.py:625
INFO:     127.0.0.1:32926 - "POST /mcp HTTP/1.1" 200 OK
                    INFO     Terminating session: None                                                 streamable_http.py:630
                    ERROR    Error in message router                                                   streamable_http.py:880
                             ╭────────────────── Traceback (most recent call last) ──────────────────╮                       
                             │ /usr/local/lib/python3.12/site-packages/mcp/server/streamable_http.py │                       
                             │ :831 in message_router                                                │                       
                             │                                                                       │                       
                             │   828 │   │   │   # Create a message router that distributes messages │                       
                             │   829 │   │   │   async def message_router():                         │                       
                             │   830 │   │   │   │   try:                                            │                       
                             │ ❱ 831 │   │   │   │   │   async for session_message in write_stream_r │                       
                             │   832 │   │   │   │   │   │   # Determine which request stream(s) sho │                       
                             │   833 │   │   │   │   │   │   message = session_message.message       │                       
                             │   834 │   │   │   │   │   │   target_request_id = None                │                       
                             │                                                                       │                       
                             │ /usr/local/lib/python3.12/site-packages/anyio/abc/_streams.py:35 in   │                       
                             │ __anext__                                                             │                       
                             │                                                                       │                       
                             │    32 │                                                               │                       
                             │    33 │   async def __anext__(self) -> T_co:                          │                       
                             │    34 │   │   try:                                                    │                       
                             │ ❱  35 │   │   │   return await self.receive()                         │                       
                             │    36 │   │   except EndOfStream:                                     │                       
                             │    37 │   │   │   raise StopAsyncIteration                            │                       
                             │    38                                                                 │                       
                             │                                                                       │                       
                             │ /usr/local/lib/python3.12/site-packages/anyio/streams/memory.py:111   │                       
                             │ in receive                                                            │                       
                             │                                                                       │                       
                             │   108 │   async def receive(self) -> T_co:                            │                       
                             │   109 │   │   await checkpoint()                                      │                       
                             │   110 │   │   try:                                                    │                       
                             │ ❱ 111 │   │   │   return self.receive_nowait()                        │                       
                             │   112 │   │   except WouldBlock:                                      │                       
                             │   113 │   │   │   # Add ourselves in the queue                        │                       
                             │   114 │   │   │   receive_event = Event()                             │                       
                             │                                                                       │                       
                             │ /usr/local/lib/python3.12/site-packages/anyio/streams/memory.py:93 in │                       
                             │ receive_nowait                                                        │                       
                             │                                                                       │                       
                             │    90 │   │                                                           │                       
                             │    91 │   │   """                                                     │                       
                             │    92 │   │   if self._closed:                                        │                       
                             │ ❱  93 │   │   │   raise ClosedResourceError                           │                       
                             │    94 │   │                                                           │                       
                             │    95 │   │   if self._state.waiting_senders:                         │                       
                             │    96 │   │   │   # Get the item from the next sender                 │                       
                             ╰───────────────────────────────────────────────────────────────────────╯                       
                             ClosedResourceError

Rollback to 1.11.0 fix the issue.

Probably addressed by #1188

same problem here and mentioned PR has been rejected

Same problem here

for what it's worth (maybe not related)

MCP version: 1.12.2
i initially had

mcp.run(transport="http", host="0.0.0.0", port=8199, path="/mcp")
07/29/25 08:52:31] INFO     Starting MCP server 'Assistant' with transport 'http' on http://0.0.0.0:8199/mcp      


curl -X GET http://localhost:8199/mcp
INFO:     127.0.0.1:41170 - "GET /mcp HTTP/1.1" 307 Temporary Redirect

but then changing to

mcp.run(transport="http", host="0.0.0.0", port=8199, path="/dmp") # could have stayed with /mcp
[07/29/25 08:54:54] INFO     Starting MCP server 'Assistant' with transport 'http' on http://0.0.0.0:8199/dmp  

curl -X GET http://localhost:8199/dmp/mcp
{"jsonrpc":"2.0","id":" ....

so that works i just had to add /mcp after my path

@huineng

@huineng from my point of view, not related to this issue.

Here any request to the MCP server in the HTTP Streamable mode produces an error in the logs.

Same problem here

MCP version: 1.12.2

use _handle_stateless_request > run_stateless_server > http_transport.connect() > for session_message in write_stream_reader
It will go in twice, and an exception(yio.ClosedResourceError) will be thrown when the second request has been closed

View logs：

[2025-07-31 15:10:41,884][MainThread:19320][task_id:mcp.server.streamable_http][streamable_http.py:630][INFO][Terminating session: None]
[2025-07-31 15:10:41,885][MainThread:19320][task_id:mcp.server.streamable_http][streamable_http.py:880][ERROR][Error in message router]
Traceback (most recent call last):
  File "d:\project\bpaas\apihub-mcp-server\.venv\Lib\site-packages\mcp\server\streamable_http.py", line 831, in message_router
    async for session_message in write_stream_reader:
    ...<46 lines>...
            )
  File "d:\project\bpaas\apihub-mcp-server\.venv\Lib\site-packages\anyio\abc\_streams.py", line 35, in __anext__
    return await self.receive()
           ^^^^^^^^^^^^^^^^^^^^
  File "d:\project\bpaas\apihub-mcp-server\.venv\Lib\site-packages\anyio\streams\memory.py", line 111, in receive
    return self.receive_nowait()
           ~~~~~~~~~~~~~~~~~~~^^
  File "d:\project\bpaas\apihub-mcp-server\.venv\Lib\site-packages\anyio\streams\memory.py", line 93, in receive_nowait
    raise ClosedResourceError
anyio.ClosedResourceError

Terminating has already released memory first

debug for : first

debug for : second

issues：#1219

Probably addressed by #1188

Would anyone be able to confirm whether this is still ocurring?

still present for me in 1.13.1

still present for me in 1.14.0

Still present for me in 1.15.0 but only if I set json_response=True

I still have issues with this streaming http server. how can I send you debug info? https://docs.ahrefs.com/docs/mcp/reference/introduction

I still have issues with this streaming http server. how can I send you debug info? https://docs.ahrefs.com/docs/mcp/reference/introduction

Is your issue with the ahrefs server specifically or something you built? Are you running a server yourself or you mean you have trouble connecting to the ahrefs mcp server?

I have trouble connecting through chatmcp. The MCP server itself works when using it through my ide with the same setup. It's a streaming http server.

Is there a way I can provide you with logs

I have trouble connecting through chatmcp. The MCP server itself works when using it through my ide with the same setup. It's a streaming http server.

Is there a way I can provide you with logs

Just paste them here in this issue or share a gist if it's a lot

@felixweinberger

@felixweinberger This is bloating our logs and can be easily reproduced as follows:

Install PyCLI MCP
```
pip install pycli-mcp
```
Install MCP Inspector
```
npm i @modelcontextprotocol/inspector
```
In one shell session run the server using its own CLI:
```
pycli-mcp pycli_mcp.cli:pycli_mcp
```

In another shell session query the server using the inspector:

mcp-inspector --cli --transport http http://localhost:8000/mcp/ --method tools/list

Notice output from the server that is similar to the following:

❯ pycli-mcp pycli_mcp.cli:pycli_mcp
Serving: pycli-mcp
INFO:     Started server process [62884]
INFO:     Waiting for application startup.
INFO:     Application startup complete.
INFO:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
INFO:     127.0.0.1:57660 - "POST /mcp/ HTTP/1.1" 200 OK
Error in message router
Traceback (most recent call last):
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\mcp\server\streamable_http.py", line 831, in message_router
    async for session_message in write_stream_reader:
    ...<45 lines>...
            )
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\anyio\abc\_streams.py", line 41, in __anext__
    return await self.receive()
          ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\anyio\streams\memory.py", line 111, in receive
    return self.receive_nowait()
          ~~~~~~~~~~~~~~~~~~~^^
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\anyio\streams\memory.py", line 93, in receive_nowait
    raise ClosedResourceError
anyio.ClosedResourceError
INFO:     127.0.0.1:57662 - "POST /mcp/ HTTP/1.1" 202 Accepted
INFO:     127.0.0.1:57660 - "GET /mcp/ HTTP/1.1" 200 OK
INFO:     127.0.0.1:57664 - "POST /mcp/ HTTP/1.1" 200 OK
ERROR:mcp.server.streamable_http:Error in message router
Traceback (most recent call last):
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\mcp\server\streamable_http.py", line 831, in message_router
    async for session_message in write_stream_reader:
    ...<45 lines>...
            )
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\anyio\abc\_streams.py", line 41, in __anext__
    return await self.receive()
          ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\anyio\streams\memory.py", line 111, in receive
    return self.receive_nowait()
          ~~~~~~~~~~~~~~~~~~~^^
  File "C:\Users\ofek\AppData\Roaming\uv\tools\pycli-mcp\Lib\site-packages\anyio\streams\memory.py", line 93, in receive_nowait
    raise ClosedResourceError
anyio.ClosedResourceError

Consolidating duplicate issues:

The following issues have been closed as duplicates of this one:

_handle_stateless_request ClosedResourceError #1219 - _handle_stateless_request ClosedResourceError
Race Condition in StreamableHTTP Transport Causes ClosedResourceError #1363 - Race Condition in StreamableHTTP Transport
ClosedResourceError when using FastMCP(..., stateless_http=True, json_response=True) with MCP Inspector #1658 - ClosedResourceError with FastMCP stateless_http=True

Root Cause Summary (from #1363):

This is a race condition in message_router() at streamable_http.py:959:

message_router enters async for write_stream_reader loop
The iterator calls checkpoint(), yielding control
Request completes/fails early and calls terminate(), closing the stream
message_router resumes and encounters closed stream → ClosedResourceError

Proposed Fix: PR #1384 adds explicit ClosedResourceError handling before the generic except Exception block.

Workaround (from #1363): Suppress logs via uvicorn config:

mcp.server.streamable_http:
  level: CRITICAL

_{AI Disclaimer}

@maxisbey

@maxisbey What's blocking the proposed fix that you mentioned from being merged?

Navigation Menu

Repository navigation

MCP server in the HTTP Streamable mode broken #1190

5 remaining items

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

MCP server in the HTTP Streamable mode broken #1190

Description

Activity

akolotov commented on Jul 23, 2025

danielefuselli-project commented on Jul 25, 2025

FernandoBenayas commented on Jul 27, 2025

huineng commented on Jul 29, 2025

danielefuselli-project commented on Jul 29, 2025

281743556 commented on Jul 31, 2025

281743556 commented on Jul 31, 2025

ochafik commented on Sep 5, 2025

danielefuselli-project commented on Sep 5, 2025

danielefuselli-project commented on Sep 19, 2025

elioengcomp commented on Oct 2, 2025

5 remaining items

christoph88 commented on Oct 17, 2025

felixweinberger commented on Oct 17, 2025

christoph88 commented on Oct 17, 2025

felixweinberger commented on Oct 17, 2025

ofek commented on Oct 21, 2025

maxisbey commented on Dec 2, 2025

ofek commented on Dec 2, 2025

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions