diff --git a/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py b/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py index 6042e269d8c..6c9fe97fc69 100644 --- a/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py +++ b/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py @@ -18,7 +18,8 @@ def save_context(self, details, workflow_manage): def execute(self, mcp_servers, mcp_server, mcp_tool, tool_params, **kwargs) -> NodeResult: servers = json.loads(mcp_servers) - params = self.handle_variables(tool_params) + params = json.loads(json.dumps(tool_params)) + params = self.handle_variables(params) async def call_tool(s, session, t, a): async with MultiServerMCPClient(s) as client: