feat(task-worktree): 桥接 DSH worktree 插件——补共享联接、锁归属 pw:<name>、修释放不掉
诉求最初是升级 dsh-task-worktree：实测已装 0.4.6 = npm dist-tags.latest，无需升级； 真正的缺口是本仓 skill 看不见插件建的树（.dsh-worktrees/），故按用户追加指令把两套 系统接起来。回收方向刻意不打通：本 skill 永不删插件的树。 脚本 task_worktree.py：新增 plugin 子命令 list/adopt/unadopt，事实源是 git worktree list（不是插件 manifest，免得被绕过）；adopt 只补缺失的 .venv 与 simulator/SDL2 联接，已有联接跳过、实体目录绝不碰；锁归属用 pw:<name> 前缀；new 顺带提示另有 N 棵 插件树、不占活跃上限 3。 一并修一处真 bug：lock release --bench-pass 在任务无台账时先 EnvError 退出、锁释放 不掉，导致每个任务的 done 收口连坐失败；现在改为警告后仍然释放。 keil-build：default_lock_task() 增加 .dsh-worktrees/ 反推分支，插件树内的构建归属 pw:<name> 而不是兜底的 build-cli（主树行为未变，本次 @build 实测仍走 build-cli）。 .gitignore 预先忽略 .dsh-worktrees/，让插件的 ensureIgnored() 找到同一字面量、不再 改写这份受控文件。check_doc_links / check_layer_deps / gen_refgraph 三处扫描面同步 排除：仓里再放一份仓会让 doc-links 假红、并让生成的配图字节漂移到 generated-fresh。 文档：并行任务工作树方案新增 §3.4 两套系统边界对照；SKILL.md 加 §F 共存一节，同时把 §B 从 53 行压到 29 行（净 +39，用户此前在飞的改写已 rebase 保留、未被覆盖）。 验证：@build 0 错误 0 警告；scripts/ci_local.py 48 根提交期钩子与 gitlint 全绿； check_doc_links --all --sections-strict 通过（2596 章节引用、无法判定 0）；id-check-new 通过；改动文件字节体检无 BOM、CRLF 与 U+FFFD。桥接行为在临时 scratch 仓端到端跑过 （adopt 建两个 reparse、unadopt 只摘联接、pw 锁取放、缺台账也能释放、越界 name 退 2）。
This commit is contained in:
@@ -82,6 +82,15 @@ BASE_BRANCH = os.environ.get("DTU_TASK_BASE", "v2-on-ui")
|
||||
STATE_DIR = WT_ROOT / ".state"
|
||||
LOCKS_DIR = STATE_DIR / "locks"
|
||||
|
||||
# DSH 的 worktree 插件（包名 dsh-task-worktree；模型工具 worktree_create、人类命令
|
||||
# /worktree）把任务树建在**仓库内**这个命名空间下，与本 skill 的仓外 _wt/ 刻意分开。
|
||||
# .gitignore 里预置同名规则，正是为了让插件的 ensureIgnored() 见到就跳过、
|
||||
# 不在会话中途往这份受控文件里追加一行。
|
||||
PLUGIN_ROOT = REPO_ROOT / ".dsh-worktrees"
|
||||
PLUGIN_NAMESPACE = "worktree" # 插件侧 WORKTREE_NAMESPACE：name 即分支尾段
|
||||
PLUGIN_SUBDIR = PLUGIN_ROOT / PLUGIN_NAMESPACE
|
||||
PLUGIN_LOCK_PREFIX = "pw" # 插件树在锁 payload 里的持有者前缀
|
||||
|
||||
|
||||
# --------------------------------------------------------------------- 基础工具
|
||||
|
||||
@@ -390,9 +399,163 @@ def bootstrap(wt: Path):
|
||||
return made
|
||||
|
||||
|
||||
# --------------------------------------------------------------------- DSH 插件工作树
|
||||
#
|
||||
# 插件建的树（.dsh-worktrees/worktree/<name>）缺三样东西，下面的命令逐条补。
|
||||
# 回收**不在这里**：插件树由「/worktree remove|prune」收，done/abort 也不该拿去处理它。
|
||||
# 1. 共享联接——没有 .venv 与 simulator 的 SDL2 SDK，插件树里「.venv\Scripts\python.exe」
|
||||
# 直接找不到解释器：@build、ci_local.py、所有 scripts/check_*.py 全部起跑失败；
|
||||
# 2. 可见性——插件树不在台账里，「list」看不见它，3 个活跃名额也只数登记任务；
|
||||
# 3. 独占资源归属——build 锁由 keil_build.py 自持自释（按 cwd 反推持有者名，
|
||||
# 插件树里算成 pw:<name>），bench 锁仍要人占，占锁名得和「lock status」对得上。
|
||||
|
||||
|
||||
def plugin_lock_owner(name: str) -> str:
|
||||
"""插件树在锁 payload 里的持有者名：pw:<name>（多段名压平成 -）。
|
||||
|
||||
必须与 keil_build.py 的 default_lock_task() 对同一种树算出的名字一致——这样构建
|
||||
自持自释留下的归属，和手工「lock acquire bench --task pw:x」才是同一个可 grep 的标识。
|
||||
"""
|
||||
# 与 plugin_dir_for 同样容忍「worktree/」前缀，否则同一棵树会出现两个持有者名
|
||||
# （pw:refactor-logging vs pw:worktree-refactor-logging），lock status 就散了。
|
||||
segs = [s for s in name.replace(os.sep, "/").strip("/").split("/") if s]
|
||||
if segs and segs[0] == PLUGIN_NAMESPACE:
|
||||
segs = segs[1:]
|
||||
return "{}:{}".format(PLUGIN_LOCK_PREFIX, "-".join(segs) or "?")
|
||||
|
||||
|
||||
def plugin_dir_for(name: str) -> Path:
|
||||
"""插件 worktree 名 → 树目录；**只允许落在 .dsh-worktrees/worktree/ 里面**。
|
||||
|
||||
adopt/unadopt 会在解析出的目录上建/摘目录联接；不加这道闸，等于允许把主工作树或
|
||||
任意 _wt 目录当插件树动手（联接会遮蔽真实内容，事后很难看出来）。
|
||||
"""
|
||||
raw = (name or "").strip().replace(os.sep, "/").strip("/")
|
||||
if not raw:
|
||||
raise EnvError("缺插件 worktree 名（先跑「plugin list」看现有树）")
|
||||
if raw == PLUGIN_NAMESPACE or raw.startswith(PLUGIN_NAMESPACE + "/"):
|
||||
raw = raw[len(PLUGIN_NAMESPACE):].strip("/")
|
||||
p = (PLUGIN_SUBDIR / raw).resolve()
|
||||
base = PLUGIN_SUBDIR.resolve()
|
||||
if p == base or base not in p.parents:
|
||||
raise EnvError("拒绝 {}：只接受 {} 里面的树".format(p, PLUGIN_SUBDIR))
|
||||
return p
|
||||
|
||||
|
||||
def plugin_trees():
|
||||
""".dsh-worktrees/worktree/ 下的工作树（事实源 = git worktree list，不读插件 manifest）。
|
||||
|
||||
manifest.json 是插件私有格式（MANIFEST_VERSION 1，字段随版本变），而 git 的注册表
|
||||
同时覆盖「插件正常建的树」和「manifest 丢了 / 树被手工删」的残留——桥接命令要看的
|
||||
是真实存在的东西。
|
||||
"""
|
||||
try:
|
||||
base = PLUGIN_SUBDIR.resolve()
|
||||
except OSError:
|
||||
return []
|
||||
trees = []
|
||||
for ent in worktree_entries():
|
||||
p = ent["path"]
|
||||
try:
|
||||
rp = p.resolve()
|
||||
except OSError:
|
||||
continue
|
||||
if rp == base or base not in rp.parents:
|
||||
continue
|
||||
dirty = (len(git_out("status", "--porcelain", cwd=p, check=False).splitlines())
|
||||
if p.is_dir() else -1)
|
||||
trees.append({
|
||||
"name": rp.relative_to(base).as_posix(),
|
||||
"path": str(p),
|
||||
"branch": ent.get("branch") or "(detached)",
|
||||
"dirty": dirty,
|
||||
"adopted": is_reparse(p / JUNCTION_SPECS[0][0]),
|
||||
})
|
||||
return trees
|
||||
|
||||
|
||||
def print_plugin_trees() -> int:
|
||||
"""打印插件树一览（无树则静默），返回数量——「list」与「new」共用同一事实。"""
|
||||
trees = plugin_trees()
|
||||
if not trees:
|
||||
return 0
|
||||
print()
|
||||
print("DSH 插件工作树（{} 下；**不在本 skill 台账** → 不占 {} 个名额、done/abort "
|
||||
"管不到，回收走 /worktree remove|prune）：".format(PLUGIN_SUBDIR, MAX_CONCURRENT))
|
||||
print("{:<26} {:<34} {:>4} {:>6}".format("名称", "分支", "脏", "联接"))
|
||||
for t in trees:
|
||||
print("{:<26} {:<34} {:>4} {:>6}".format(
|
||||
t["name"], t["branch"], "-" if t["dirty"] < 0 else str(t["dirty"]),
|
||||
"已联" if t["adopted"] else "未联"))
|
||||
if any(not t["adopted"] for t in trees):
|
||||
print("未联的进去跑不了 Python：「plugin adopt <name>」只建共享联接，不碰树内容")
|
||||
return len(trees)
|
||||
|
||||
|
||||
def adopt_junctions(wt: Path):
|
||||
"""只补**缺失**的共享联接（已联的跳过、实体目录绝不碰），返回 (已有, 本次新建)。"""
|
||||
already, made = [], []
|
||||
for rel, desc in JUNCTION_SPECS:
|
||||
link = wt / rel
|
||||
if is_reparse(link):
|
||||
already.append(rel)
|
||||
continue
|
||||
if os.path.lexists(str(link)):
|
||||
print("[warn] {} 已是实体目录/文件（不是联接）——不动它".format(rel))
|
||||
already.append(rel)
|
||||
continue
|
||||
target = REPO_ROOT / rel
|
||||
if not target.exists():
|
||||
print("[skip] {}（{}）主线里不存在，跳过".format(rel, desc))
|
||||
continue
|
||||
try:
|
||||
make_junction(link, target)
|
||||
except (Fail, EnvError) as err:
|
||||
print("[WARN] {} 联接失败：{}".format(rel, err))
|
||||
continue
|
||||
made.append(rel)
|
||||
print("[ok] 联接 {} -> {}".format(rel, target))
|
||||
return already, made
|
||||
|
||||
|
||||
def cmd_plugin(a) -> int:
|
||||
if a.action == "list":
|
||||
if print_plugin_trees() == 0:
|
||||
print("（{} 下没有插件工作树）".format(PLUGIN_SUBDIR))
|
||||
print(" 建法：新会话输入框选「Worktree模式」/ 让模型调 worktree_create / "
|
||||
"/worktree create <name>")
|
||||
print(" 建完回来「plugin adopt <name>」补共享联接，才能在里面跑 @build 与门禁。")
|
||||
return EXIT_OK
|
||||
|
||||
wt = plugin_dir_for(a.name)
|
||||
if not wt.is_dir():
|
||||
raise EnvError("目录不存在：{}（先用插件建树：/worktree create 或 worktree_create）".format(wt))
|
||||
|
||||
if a.action == "adopt":
|
||||
if git("rev-parse", "--git-dir", cwd=wt, check=False).returncode != 0:
|
||||
raise EnvError("{} 不是 git 工作树（别拿普通目录当插件树）".format(wt))
|
||||
print("为插件树补共享联接：{}".format(wt))
|
||||
already, made = adopt_junctions(wt)
|
||||
owner = plugin_lock_owner(a.name)
|
||||
print()
|
||||
print("[ok] 联接：已有 {} 个、本次新建 {} 个".format(len(already), len(made)))
|
||||
print("该目录现在可以跑 @build / ci_local.py / @test；build 锁由 keil_build.py "
|
||||
"自持自释，持有者名就是 {}".format(owner))
|
||||
print("上台架前：$TW lock acquire bench --task {} --note <说明>".format(owner))
|
||||
print("下台架后：$TW lock release bench --task {}".format(owner))
|
||||
print("回收仍归插件：/worktree remove {}（本 skill 不删插件树）".format(a.name))
|
||||
return EXIT_OK
|
||||
|
||||
removed = [rel for rel, _spec in JUNCTION_SPECS if remove_junction(wt / rel)]
|
||||
print("[ok] 摘掉联接：{}（只摘联接本身，绝不动目标内容与树里文件）".format(
|
||||
"、".join(removed) if removed else "无（该树没有联接着）"))
|
||||
return EXIT_OK
|
||||
|
||||
|
||||
# --------------------------------------------------------------------- 子进程脚本
|
||||
|
||||
|
||||
|
||||
def regen(cwd: Path) -> None:
|
||||
run_script("scripts/gen_task_table.py", ["--write"], cwd, "重生成 FreeRTOS 任务表")
|
||||
if list((Path(cwd) / "MDK-ARM").glob("**/*.map")):
|
||||
@@ -557,6 +720,10 @@ def cmd_new(a) -> int:
|
||||
raise EnvError("已有 {} 个活跃任务（上限 {}）；先 done/abort，或加 --force".format(
|
||||
len(active), MAX_CONCURRENT))
|
||||
|
||||
n_plugin = len(plugin_trees())
|
||||
if n_plugin:
|
||||
print("[i] 另有 {} 个 DSH 插件工作树（.dsh-worktrees/，不计入上限 {}）；"
|
||||
"磁盘与 UV4 / 台架仍是共享资源——「plugin list」看清单".format(n_plugin, MAX_CONCURRENT))
|
||||
WT_ROOT.mkdir(parents=True, exist_ok=True)
|
||||
print("[1/3] 建工作树（分支 {}，基线 {}{}）…".format(
|
||||
branch, a.base, "，跳过 LFS smudge" if a.lean else ""))
|
||||
@@ -588,6 +755,7 @@ def cmd_list(a) -> int:
|
||||
states = all_states()
|
||||
if not states:
|
||||
print("（没有任务空间。用 `new <ID> <slug>` 建一个）")
|
||||
print_plugin_trees()
|
||||
return EXIT_OK
|
||||
print("{:<12} {:<32} {:>5} {:>5} {:>4} {}".format(
|
||||
"任务", "分支", "落后", "领先", "脏", "台架"))
|
||||
@@ -612,6 +780,7 @@ def cmd_list(a) -> int:
|
||||
else:
|
||||
print("锁 {:<6} {} 持有（已 {:.1f} 小时，于 {}）".format(
|
||||
n, info.get("task"), lock_age_hours(info), info.get("at")))
|
||||
print_plugin_trees()
|
||||
return EXIT_OK
|
||||
|
||||
|
||||
@@ -692,10 +861,19 @@ def cmd_lock(a) -> int:
|
||||
if a.bench_pass:
|
||||
if not a.task:
|
||||
raise EnvError("--bench-pass 需要 --task <ID>")
|
||||
st = load_state(a.task)
|
||||
st["bench_pass"] = True
|
||||
save_state(st)
|
||||
print("[ok] 已为任务 {} 记录台架 PASS".format(a.task))
|
||||
# 非登记持有者（lead 的验收窗、插件树 pw:*）没有台账。以前这里先 load_state
|
||||
# 就抛「任务 X 不存在（缺台账）」，**根本走不到释放**：锁还挂着，而 done 的前置
|
||||
# 会因活锁判失败——一个名字没登记，就挡住所有任务的收口。现在降级为显式告警 +
|
||||
# 照常释放：PASS 没进台账是事实，但不该拿「锁放不掉」当代价。
|
||||
if state_file(a.task).is_file():
|
||||
st = load_state(a.task)
|
||||
st["bench_pass"] = True
|
||||
save_state(st)
|
||||
print("[ok] 已为任务 {} 记录台架 PASS".format(a.task))
|
||||
else:
|
||||
print("[warn] 任务 {} 无台账（{}）→ **跳过 PASS 记录，仅释放锁**；要把 PASS 留在"
|
||||
"台账里就得用已「new」出来的任务 ID 占锁，或把验收结论写进主干提交说明/文档"
|
||||
.format(a.task, state_file(a.task)))
|
||||
ok, msg = lock_release(a.name, a.task, force=a.force)
|
||||
print(msg)
|
||||
return EXIT_OK if ok else EXIT_FAIL
|
||||
@@ -874,6 +1052,12 @@ def build_parser():
|
||||
help="release bench 时顺带为该任务记录台架 PASS")
|
||||
p.set_defaults(func=cmd_lock)
|
||||
|
||||
p = sub.add_parser("plugin", help="DSH worktree 插件的树（.dsh-worktrees/）：list / adopt / unadopt")
|
||||
p.add_argument("action", choices=["list", "adopt", "unadopt"])
|
||||
p.add_argument("name", nargs="?", default="",
|
||||
help="插件 worktree 名（可带 worktree/ 前缀或多段斜杠）")
|
||||
p.set_defaults(func=cmd_plugin)
|
||||
|
||||
p = sub.add_parser("done", help="回收：预演 → 合入主干 → 审计 → 重生成 → 门禁 → 清场")
|
||||
p.add_argument("task_id")
|
||||
p.add_argument("--base", default=None)
|
||||
|
||||
Reference in New Issue
Block a user