wanwu/deer-flow
1
0
Fork 0
mirror of https://gitee.com/wanwujie/deer-flow synced 2026-04-03 06:12:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: langchain-mcp-adapters version conflict (#500)

Browse Source 
* fix: langchain-mcp-adapters version conflict

* fix the lint error
This commit is contained in:
Willem Jiang
2025-08-04 10:36:31 +08:00
committed by GitHub
parent ba7509d9ae
commit 4218cddab5
2 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/graph/nodes.py
View File

@@ -458,16 +458,17 @@ async def _setup_and_execute_agent_step(
# Create and execute agent with MCP tools if available
if mcp_servers:
async with MultiServerMCPClient(mcp_servers) as client:
loaded_tools = default_tools[:]
for tool in client.get_tools():
if tool.name in enabled_tools:
tool.description = (
f"Powered by '{enabled_tools[tool.name]}'.\n{tool.description}"
)
loaded_tools.append(tool)
agent = create_agent(agent_type, agent_type, loaded_tools, agent_type)
return await _execute_agent_step(state, agent, agent_type)
client = MultiServerMCPClient(mcp_servers)
loaded_tools = default_tools[:]
all_tools = await client.get_tools()
for tool in all_tools:
if tool.name in enabled_tools:
tool.description = (
f"Powered by '{enabled_tools[tool.name]}'.\n{tool.description}"
)
loaded_tools.append(tool)
agent = create_agent(agent_type, agent_type, loaded_tools, agent_type)
return await _execute_agent_step(state, agent, agent_type)
else:
# Use default tools if no MCP servers are configured
agent = create_agent(agent_type, agent_type, default_tools, agent_type)

4
tests/integration/test_nodes.py
View File

@@ -1110,7 +1110,7 @@ def patch_multiserver_mcp_client():
async def __aexit__(self, exc_type, exc, tb):
pass
def get_tools(self):
async def get_tools(self):
return [
FakeTool("toolA", "descA"),
FakeTool("toolB", "descB"),
@@ -1244,7 +1244,7 @@ async def test_setup_and_execute_agent_step_with_mcp_tools_description_update(
async def __aexit__(self, exc_type, exc, tb):
pass
def get_tools(self):
async def get_tools(self):
return [FakeTool("toolA", "descA")]
with patch("src.graph.nodes.MultiServerMCPClient", return_value=FakeClient()):