Skip to content

Commit aca621e

Browse files
committed
add typecheck
1 parent 333b32c commit aca621e

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/mcp/client/streamable_http.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -254,9 +254,10 @@ async def _handle_resumption_request(self, ctx: RequestContext) -> None:
254254
async def _send_error_response(self, ctx: RequestContext, error: Exception) -> None:
255255
"""Send an error response to the client."""
256256
error_data = ErrorData(code=32000, message=str(error))
257-
jsonrpc_error = JSONRPCError(jsonrpc="2.0", id=ctx.session_message.message.root.id, error=error_data)
258-
session_message = SessionMessage(message=JSONRPCMessage(jsonrpc_error))
259-
await ctx.read_stream_writer.send(session_message)
257+
if isinstance(ctx.session_message.message.root, JSONRPCRequest):
258+
jsonrpc_error = JSONRPCError(jsonrpc="2.0", id=ctx.session_message.message.root.id, error=error_data)
259+
session_message = SessionMessage(message=JSONRPCMessage(jsonrpc_error))
260+
await ctx.read_stream_writer.send(session_message)
260261

261262
async def _handle_post_request(self, ctx: RequestContext) -> None:
262263
"""Handle a POST request with response processing."""

0 commit comments

Comments
 (0)