fix: StreamableHTTPTransport got invalid json exception when receive a ping event from mcp server #28111 (#28116)
This commit is contained in:
@@ -138,6 +138,10 @@ class StreamableHTTPTransport:
|
|||||||
) -> bool:
|
) -> bool:
|
||||||
"""Handle an SSE event, returning True if the response is complete."""
|
"""Handle an SSE event, returning True if the response is complete."""
|
||||||
if sse.event == "message":
|
if sse.event == "message":
|
||||||
|
# ping event send by server will be recognized as a message event with empty data by httpx-sse's SSEDecoder
|
||||||
|
if not sse.data.strip():
|
||||||
|
return False
|
||||||
|
|
||||||
try:
|
try:
|
||||||
message = JSONRPCMessage.model_validate_json(sse.data)
|
message = JSONRPCMessage.model_validate_json(sse.data)
|
||||||
logger.debug("SSE message: %s", message)
|
logger.debug("SSE message: %s", message)
|
||||||
|
|||||||
Reference in New Issue
Block a user