panyy
/
UnisKB
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: MCP calling node error #3752 (#3762)

v3.2
shaohuzhang1 2025-07-29 10:48:30 +08:00 committed by GitHub
parent 9cc051ded4
commit d33ae01d5a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py
View File

@ -4,7 +4,6 @@ import json
from typing import List from typing import List
from langchain_mcp_adapters.client import MultiServerMCPClient from langchain_mcp_adapters.client import MultiServerMCPClient
from langchain_mcp_adapters.sessions import create_session
from application.flow.i_step_node import NodeResult from application.flow.i_step_node import NodeResult
from application.flow.step_node.mcp_node.i_mcp_node import IMcpNode from application.flow.step_node.mcp_node.i_mcp_node import IMcpNode
@ -25,7 +24,7 @@ class BaseMcpNode(IMcpNode):
async def call_tool(t, a): async def call_tool(t, a):
client = MultiServerMCPClient(servers) client = MultiServerMCPClient(servers)
async with create_session(client.connections[mcp_server]) as s: async with client.session(mcp_server) as s:
return await s.call_tool(t, a) return await s.call_tool(t, a)
res = asyncio.run(call_tool(mcp_tool, params)) res = asyncio.run(call_tool(mcp_tool, params))