Function execute_tool_call

helpers/parallel_tools.py:496–544

(agent: "Agent", tool_name: str, tool_args: dict[str, Any])

async def execute_tool_call(agent: "Agent", tool_name: str, tool_args: dict[str, Any]) -> str:
    if tool_name == "parallel":
        raise ValueError("`parallel` cannot be nested inside a parallel worker.")

    tool = None
    try:
        import helpers.mcp_handler as mcp_helper

        tool = mcp_helper.MCPConfig.get_instance().get_tool(agent, tool_name)
    except ImportError:
        tool = None
    except Exception as exc:
        PrintStyle.warning(f"Failed to initialize MCP tool '{tool_name}' for parallel job: {exc}")

    if not tool:
        tool = agent.get_tool(
            name=tool_name,
            method=None,
            args=tool_args,
            message=json.dumps({"tool_name": tool_name, "tool_args": tool_args}),
            loop_data=agent.loop_data,
        )
    if not tool:
        raise ValueError(f"Tool '{tool_name}' not found or could not be initialized.")

    agent.loop_data.current_tool = tool
    try:
        await agent.handle_intervention()
        await tool.before_execution(**tool_args)
        await agent.handle_intervention()
        await call_extensions_async(
            "tool_execute_before",
            agent,
            tool_args=tool_args or {},
            tool_name=tool_name,
        )
        response = await tool.execute(**tool_args)
        await agent.handle_intervention()
        await call_extensions_async(
            "tool_execute_after",
            agent,
            response=response,
            tool_name=tool_name,
        )
        await tool.after_execution(response)
        await agent.handle_intervention()
        return response.message
    finally:
        agent.loop_data.current_tool = None


async def _cancel_job(