diff --git a/src/mcp/client/session.py b/src/mcp/client/session.py index f18cc0ef10..4f80cbb7af 100644 --- a/src/mcp/client/session.py +++ b/src/mcp/client/session.py @@ -250,6 +250,9 @@ async def __call__(self, message: IncomingMessage) -> None: ... # pragma: no br async def _default_message_handler(message: IncomingMessage) -> None: + if isinstance(message, Exception): + logger.error("ClientSession Error: %s", message) + raise message await anyio.lowlevel.checkpoint()