实战三：多 Agent 工作流搭建

周一 9:00
Planner     ─拉 PRs ──┐
                  │
5 explore    ─并行─→ owner map
                  │
5 build      ─并行─→ review brief
                  │
Slack send   ─→ 单条最终消息
                  │
                  └ DONE 9:08

        ┌── orchestrator (主 Agent / Sisyphus)
        │      plan / dispatch / merge / notify
        │
        ├── github MCP        (pull github issues/PRs)
        ├── slack MCP         (post messages)
        ├── filesystem MCP    (read CODEOWNERS)
        │
        └── subagents:
            ├── 5x explore   (每 PR 一个，找 files → owner)
            └── 5x build      (每 owner 一个, 写 review brief)

---
name: weekly-triage
version: 0.3.2
last_updated: 2026-07-23
---

# weekly-triage

## Trigger
User says "weekly triage" / "本周 triage" / "周一 review 一轮"
或 OpenCode cron mode: weekly/Mon/09:00

## Plan

1. Dispatch github.list_pull_requests to load this week's open PRs.
2. For each PR, dispatch a parallel explore subagent to:
   - Read CODEOWNERS
   - Read the diff stat files
   - Output a single owner candidate: email + rationale
3. Dispatch parallel build subagents (1 per PR) to:
   - Read that PR's full diff
   - Produce a 6-line review brief: changes, risk, owner focus
4. Merge all briefs to single markdown.
5. Send via slack.post_message to #eng-triage channel

## DONE
- One slack message in #eng-triage with markdown body

## Failure modes
- No open PRs:
  - Send 'no PRs this week' empty
- CODEOWNERS missing:
  - Skip owner step, mark brief as `unknown`
- Slack rate limited:
  - Retry once; if fails, save to artifact.md and notify milestone Hansen

# scripts/weekly_triage.py
import asyncio, json
from mcp_client import MCPClient

mcp = MCPClient.connect("github", "slack", "filesystem")

async def weekly_triage():
    prs_response = await mcp.call("github", "list_pull_requests",
                                   {"state":"open","sort":"updated","direction":"desc"})
    prs = parse(prs_response)["items"]
    if not prs:
        await post_slack("#eng-triage", "*No open PRs this week*")
        return

    # Stage 1: explore 5 个并发找 owner
    owner_tasks = [dispatch_explore(pr) for pr in prs[:5]]
    owners = await asyncio.gather(*owner_tasks)

    # Stage 2: build 5 个并发写 brief
    brief_tasks = [dispatch_build(pr, owner)
                   for pr, owner in zip(prs[:5], owners)]
    briefs = await asyncio.gather(*brief_tasks)

    # Stage 3: 合并 → slack
    body = "\n\n---\n\n".join(
        f"*PR #{pr['number']}: {pr['title']}*\nowner: {owner}\n{brief}"
        for pr, owner, brief in zip(prs[:5], owners, briefs)
    )
    await mcp.call("slack", "post_message",
                    {"channel":"#eng-triage","text":body})

async def dispatch_explore(pr: dict) -> dict:
    return await OpenCode_subagent(
        subagent_type="explore",
        prompt=f"""
[CONTEXT]
Got PR #{pr['number']} PR_title={pr['title']}
CODEOWNERS at .github/CODEOWNERS if exists.

[GOAL]
Return the actual owner for this PR: name + email

[REQUEST]
Read CODEOWNERS, identify matched owner given PR touched paths (= {pr['changed_files']})
Return JSON: {{owner: name, email: x@x, source: CODEOWNERS|git-blame|fallback:maintainer}}

[MUST NOT]
Do not modify any file.
风扇介绍.
""",
    )

async def dispatch_build(pr: dict, owner: dict) -> str:
    return await OpenCode_subagent(
        subagent_type="build",
        prompt=f"""
[CONTEXT]
PR #{pr['number']} {pr['title']} diff: {pr['diff_url']}
Owner: {owner['owner']} ({owner['email']})

[GOAL]
Write a 6-line review brief.

[REQUIRED TOOLS]
github.get_pull_request_files / read PR body / read tests

[OUTPUT]
Six lines max:
  1. PR_title
  2. Files changed (N total, K tests)
  3. Risk area (string ≤ 30 chars)
  4. Review focus (1 string)
  5. Suggested reviewer priority / 5
  6. Need extra reviewer? (yes/no)

[MUST DO]
Be terse. Avoid summary that the owner would already know.
[MUST NOT DO]
Do not propose patches. Do not review grading or opinionate.
""",
    )

# 主入口
asyncio.run(weekly_triage())

# 5 个 subagent 起码, 15 个会撞 github rate limit → 排队
# OpenCode 内置 `task` 也是 5 个并发
SEMAPHORE = asyncio.Semaphore(5)

async def dispatch_explore(pr: dict) -> dict:
    async with SEMAPHORE:
        return await OpenCode_subagent(...)

async def safe_gather(coro_factories, *args):
    results = await asyncio.gather(*[c() for c in coro_factories],
                                   return_exceptions=True)
    return [r if not isinstance(r, Exception) else None for r in results]

try:
    owners = await asyncio.wait_for(asyncio.gather(*owner_tasks), timeout=120)
except asyncio.TimeoutError:
    owners = [None] * len(owner_tasks)  # 后续根据 None 做降级

async def dispatch_build_with_owner(pr: dict, explore_result: str) -> str:
    enriched_prompt = f"""
[CONTEXT]
Explore phase output:
{explore_result}

Now generate the brief.
"""
    return await OpenCode_subagent(subagent_type="build", prompt=enriched_prompt)

async def validate_brief(text: str) -> bool:
    if len(text.split("\n")) != 7:
        return False  # 6 lines + last line empty
    if "PR_title" not in text[0:200]:
        return False  # 必须有
    return True

# in main:
for pr, brief in zip(prs[:5], briefs):
    if not await validate_brief(brief):
        # retry once
        brief = await dispatch_build(pr, ...)
        # cache trace

9:00 启动 weekly-triage skill (用户明说 CRON)
9:01 "拉了 5 个 PRs"
9:02 5 个 explore 同时跑
9:03 explore 阶段结束,4/5 成功（1 个 CODEOWNERS 不全）
9:03 5 个 build 同时跑
9:04 build 阶段结束,5/5 brief 都 6 行
9:05 slack 消息发出
9:08 完成,duration ≈ 8m, consumed 18k tokens

from pathlib import Path
import json, time

def log_stage(stage: str, payload: dict):
    out = Path(".triage") / f"{stage}.json"
    out.write_text(json.dumps({"ts": time.time(), **payload}, ensure_ascii=False,
                              indent=2, default=str))

log_stage("start", {"prs_count": len(prs)})
log_stage("explore_done", {"owners": [o for o in owners]})
log_stage("build_done", {"briefs_size": [len(b) for b in briefs]})
log_stage("slack_sent", {"status": "ok"})