When any handler raises an McpError, we pass it as a response

dsp-ant · dsp-ant · commit afe1c0913a66 · 2024-11-22T22:54:35.000Z
diff --git a/src/mcp/server/__init__.py b/src/mcp/server/__init__.py
@@ -12,6 +12,7 @@
 from mcp.server.session import ServerSession
 from mcp.server.stdio import stdio_server as stdio_server
 from mcp.shared.context import RequestContext
+from mcp.shared.exceptions import McpError
 from mcp.shared.session import RequestResponder
 
 logger = logging.getLogger(__name__)
@@ -367,6 +368,8 @@ async def run(
                                         )
                                     )
                                     response = await handler(req)
+                                except McpError as err:
+                                    response = err.error
                                 except Exception as err:
                                     if raise_exceptions:
                                         raise err
