fix(mcp-tool): using the async invocation for MCP tools (#840)

Author: WillemJiang

src/graph/nodes.py

@@ -1125,10 +1125,11 @@ async def _execute_agent_step(
         )
 
     try:
-        # Use stream from the start to capture messages in real-time
+        # Use astream (async) from the start to capture messages in real-time
         # This allows us to retrieve accumulated messages even if recursion limit is hit
+        # NOTE: astream is required for MCP tools which only support async invocation
         accumulated_messages = []
-        for chunk in agent.stream(
+        async for chunk in agent.astream(
             input=agent_input,
             config={"recursion_limit": recursion_limit},
             stream_mode="values",

tests/integration/test_nodes.py

@@ -1107,12 +1107,12 @@ async def ainvoke(input, config):
         # Simulate agent returning a message list
         return {"messages": [MagicMock(content="result content")]}
 
-    def stream(input, config, stream_mode):
-        # Simulate agent.stream() yielding messages
+    async def astream(input, config, stream_mode):
+        # Simulate agent.astream() yielding messages (async generator)
         yield {"messages": [MagicMock(content="result content")]}
 
     agent.ainvoke = ainvoke
-    agent.stream = stream
+    agent.astream = astream
     return agent
 
 
@@ -1177,12 +1177,12 @@ async def ainvoke(input, config):
         assert any("DO NOT include inline citations" in m.content for m in messages)
         return {"messages": [MagicMock(content="resource result")]}
 
-    def stream(input, config, stream_mode):
-        # Simulate agent.stream() yielding messages
+    async def astream(input, config, stream_mode):
+        # Simulate agent.astream() yielding messages (async generator)
         yield {"messages": [MagicMock(content="resource result")]}
 
     agent.ainvoke = ainvoke
-    agent.stream = stream
+    agent.astream = astream
     with patch(
         "src.graph.nodes.HumanMessage",
         side_effect=lambda content, name=None: MagicMock(content=content, name=name),
@@ -2424,8 +2424,8 @@ async def mock_ainvoke(input, config):
         ]
         return {"messages": messages}
 
-    def stream(input, config, stream_mode):
-        # Simulate agent.stream() yielding the final messages
+    async def astream(input, config, stream_mode):
+        # Simulate agent.astream() yielding the final messages (async generator)
         messages = [
             AIMessage(
                 content="I'll search for information about this topic.",
@@ -2460,7 +2460,7 @@ def stream(input, config, stream_mode):
         yield {"messages": messages}
 
     agent.ainvoke = mock_ainvoke
-    agent.stream = stream
+    agent.astream = astream
 
     # Execute the agent step
     with patch(
@@ -2556,8 +2556,8 @@ async def mock_ainvoke(input, config):
         ]
         return {"messages": messages}
 
-    def stream(input, config, stream_mode):
-        # Simulate agent.stream() yielding the messages
+    async def astream(input, config, stream_mode):
+        # Simulate agent.astream() yielding the messages (async generator)
         messages = [
             AIMessage(
                 content="I'll search for information.",
@@ -2579,7 +2579,7 @@ def stream(input, config, stream_mode):
         yield {"messages": messages}
 
     agent.ainvoke = mock_ainvoke
-    agent.stream = stream
+    agent.astream = astream
 
     with patch(
         "src.graph.nodes.HumanMessage",
@@ -2639,8 +2639,8 @@ async def mock_ainvoke(input, config):
         ]
         return {"messages": messages}
 
-    def stream(input, config, stream_mode):
-        # Simulate agent.stream() yielding messages without tool calls
+    async def astream(input, config, stream_mode):
+        # Simulate agent.astream() yielding messages without tool calls (async generator)
         messages = [
             AIMessage(
                 content="Based on my knowledge, here is the answer without needing to search."
@@ -2649,7 +2649,7 @@ def stream(input, config, stream_mode):
         yield {"messages": messages}
 
     agent.ainvoke = mock_ainvoke
-    agent.stream = stream
+    agent.astream = astream
 
     with patch(
         "src.graph.nodes.HumanMessage",