同步 herdr-issue skill:阻擋關係改用 Gitea 原生 issue dependencies

Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
2026-10-07 16:38:47 +08:00
co-authored by Claude Sonnet 5.5
parent d1cd61ee15
commit 03ec8318b8
5 changed files with 90 additions and 32 deletions
+26 -17
View File
@@ -1,10 +1,12 @@
#!/usr/bin/env python3
"""列出可執行的議題。輸入:open.json agents.json tabs.json"""
import json, re, sys
"""列出可執行的議題。輸入:open.json agents.json tabs.json owner/repo
阻擋關係只認 Gitea 原生 issue dependencies(tea api),不看議題內文。"""
import json, re, subprocess, sys
open_issues = json.load(open(sys.argv[1]))
agents = json.load(open(sys.argv[2]))
tabs = json.load(open(sys.argv[3]))
repo = sys.argv[4]
def find(o, k):
if isinstance(o, dict):
@@ -19,9 +21,6 @@ def find(o, k):
def labels(i): return [l.strip() for l in (i.get("labels") or "").split() if l.strip()] if isinstance(i.get("labels"), str) else [l["name"] for l in i.get("labels") or []]
open_idx = {i["index"] for i in open_issues}
by_idx = {i["index"]: i for i in open_issues}
# Herdr 裡活著的 agent:名稱 issue-N,或掛在標籤 #N 的 tab 上
running = set()
for a in find(agents, "agents") or []:
@@ -32,14 +31,25 @@ for t in find(tabs, "tabs") or []:
m = re.fullmatch(r"#(\d+)", str(t.get("label") or ""))
if m and t.get("tab_id") in agent_tabs: running.add(m.group(1))
def blockers(i):
m = re.search(r"Blocked by:\s*([^\n]*)", i.get("body") or "")
return re.findall(r"#(\d+)", m.group(1)) if m else []
def open_blockers(n):
"""擋住 #n 的 open 依賴。tea api 遇到 HTTP 錯誤仍 exit 0,所以回應不是陣列就當失敗,整個停下。"""
raw = subprocess.run(["tea", "api", "--repo", repo, f"/repos/{{owner}}/{{repo}}/issues/{n}/dependencies"],
capture_output=True, text=True).stdout
try: d = json.loads(raw)
except Exception: d = None
if not isinstance(d, list):
sys.exit(f"herdr-issue: 讀取 #{n} 的依賴失敗:{raw.strip()[:300]}")
out = []
for i in d:
if i.get("state") != "open": continue
r = (i.get("repository") or {}).get("full_name", "")
out.append(("#" if r in ("", repo) else r + "#") + str(i["number"]))
return out
def spec(i):
return next((l for l in labels(i) if l.startswith("規格/#") or l.startswith("總覽/#")), "")
runnable, blocked, stale = [], [], []
runnable, stale = [], []
for i in sorted(open_issues, key=lambda x: int(x["index"])):
ls = labels(i)
if "ready-for-agent" not in ls: continue
@@ -48,17 +58,16 @@ for i in sorted(open_issues, key=lambda x: int(x["index"])):
if n in running: continue
if "in-progress" in ls:
stale.append(n); continue
open_blockers = [b for b in blockers(i) if b in open_idx]
if open_blockers:
blocked.append((n, open_blockers)); continue
if open_blockers(n): continue
runnable.append((n, spec(i), i["title"]))
print(f"可執行({len(runnable)}):編號\t規格\t標題")
for n, s, t in runnable:
print(f"#{n}\t{s}\t{t}")
if runnable:
print(f"可執行({len(runnable)}):編號\t規格\t標題")
for n, s, t in runnable:
print(f"#{n}\t{s}\t{t}")
else:
print("目前沒有可執行的議題。")
print()
print("Herdr 執行中:" + (" ".join(f"#{n}" for n in sorted(running, key=int)) or "無"))
if stale:
print("掛 in-progress 但沒有 agent(需處理,重跑 start 會接續):" + " ".join(f"#{n}" for n in stale))
if blocked:
print("被阻擋:" + " ".join(f"#{n}←{','.join('#'+b for b in bs)}" for n, bs in blocked))