fix: handle ClosedResourceError in StreamableHTTP message router (#1384)

Co-authored-by: Max Isbey <224885523+maxisbey@users.noreply.github.com>
Co-authored-by: Marcelo Trylesinski <marcelotryle@gmail.com>
This commit is contained in:
Edison 2025-12-04 18:36:23 +08:00 • committed by GitHub
commit 9ed0b93ceb
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -1000,11 +1000,16 @@ class StreamableHTTPServerTransport:
# Stream might be closed, remove from registry
self._request_streams.pop(request_stream_id, None)
else:
logging.debug(
logger.debug(
f"""Request stream {request_stream_id} not found
for message. Still processing message as the client
might reconnect and replay."""
)
except anyio.ClosedResourceError:
if self._terminated:
logger.debug("Read stream closed by client")
else:
logger.exception("Unexpected closure of read stream in message router")
except Exception:
logger.exception("Error in message router")