S06 Subagent：给子任务一份独立上下文

TASK_TOOL = {
    "name": "task",
    "description": (
        "Run a subagent with fresh conversation context "
        "and return its final text."
    ),
    "input_schema": {
        "type": "object",
        "properties": {
            "prompt": {"type": "string", "minLength": 1},
        },
        "required": ["prompt"],
    },
}

TOOLS = [*BASE_TOOLS, TASK_TOOL]
TOOL_HANDLERS = {**BASE_HANDLERS, "task": run_subagent}

{
  "prompt": "检查 src/auth.py 的调用路径，找出重复登录请求的可能原因。先不要修改文件；返回相关函数、证据和建议验证步骤。"
}

def run_subagent(prompt: str) -> str:
    messages = [{"role": "user", "content": prompt}]
    # 之后所有子工具调用和结果都追加到这个列表

SUB_SYSTEM = (
    f"You are a coding agent at {WORKDIR}. "
    "Complete the given task, then return a concise final answer."
)

SUB_TOOLS = list(BASE_TOOLS)
SUB_HANDLERS = dict(BASE_HANDLERS)

WORKDIR = Path.cwd()

def run_write(path: str, content: str) -> str:
    # 摘录写入路径，省略异常处理与返回文案
    file_path = (WORKDIR / path).resolve()
    file_path.parent.mkdir(parents=True, exist_ok=True)
    file_path.write_text(content, encoding="utf-8")

# run_bash 中同样使用 cwd=WORKDIR

def execute_tool(block, handlers: dict) -> str:
    blocked = trigger_hooks("PreToolUse", block)
    if blocked:
        return str(blocked)

    handler = handlers.get(block.name)
    try:
        output = handler(**block.input) if handler else f"Unknown: {block.name}"
    except Exception as error:
        output = f"Error: {error}"

    trigger_hooks("PostToolUse", block, output)
    return str(output)

output = execute_tool(block, TOOL_HANDLERS)
# 如果 block.name == "task"：
# execute_tool -> run_subagent(prompt) -> 子循环结束 -> 返回文本

results.append({
    "type": "tool_result",
    "tool_use_id": block.id,
    "content": output,
})

return extract_text(response.content) or "(no summary)"

def run_subagent(prompt):
    child_messages = [user_message(prompt)]

    for turn in range(30):
        response = ask_llm(SUB_SYSTEM, SUB_TOOLS, child_messages)
        child_messages.append(assistant_message(response))
        calls = extract_tool_calls(response)

        if not calls:
            feedback = trigger_hooks("Stop", child_messages)
            if feedback:
                child_messages.append(user_message(feedback))
                continue
            return extract_text(response.content) or "(no summary)"

        results = []
        for call in calls:
            output = execute_tool(call, SUB_HANDLERS)
            results.append(tool_result(call.id, output))
        child_messages.append(user_message(results))

    return "Subagent stopped after 30 turns without a final answer."


# 父循环：仍使用自己的历史、SYSTEM 和工具表
trigger_hooks("UserPromptSubmit", query)
parent_messages.append(user_message(query))

while True:
    response = ask_llm(SYSTEM, TOOLS, parent_messages)
    parent_messages.append(assistant_message(response))
    calls = extract_tool_calls(response)

    if not calls:
        feedback = trigger_hooks("Stop", parent_messages)
        if feedback:
            parent_messages.append(user_message(feedback))
            continue
        break

    results = []
    for call in calls:
        output = execute_tool(call, TOOL_HANDLERS)
        # task 在这里同步运行上面的子循环，返回后才继续
        results.append(tool_result(call.id, output))
    parent_messages.append(user_message(results))