+j5dZddlmZddlZddlZddlmZmZddlm Z m Z dZ dZ ejdZejd Zejd ZeGd d Zdd ZeGddZdd dZddd d!dZeGddZddd d"dZeGddZddddddd d#dZgdZy)$udispatch.anu_finish_preflight — task-2731 finish/closeout preflight (dev1/dev2 마찰 분리). dev1/dev2 closeout 미완 실증 결함 중 **finish-task 끝단 마찰 3종**을 기존 guard 직접 수정 없이 별개 모듈로 분리 판정한다(expected_files 내부 유지 · canonical 0 touch): 1. **branch regex `-rN`/`+N` 안전 추출**(dev2): `task-2730-r2` → base `task-2730` 로만 추출하면 dev1 의 `task-2730` state/lock 과 충돌. revision suffix 를 인식하여 base + revision + full ref 를 분리, 정체성 충돌 0. 2. **worktree path mismatch 탐지**(dev2): `.worktrees/` 기대 vs CODE_ROOT 직접 체크아웃 불일치를 preflight 에서 탐지(경고/차단 판정). 3. **task-lock 마찰 우회 판정**(dev2): OS runner 의 result.json 수거는 task-lock / worktree / tracked 여부와 **독립**(lock-free)임을 명문화 — lock 마찰로 callback 누락 0. 순수 함수(git/subprocess 0 · 파일시스템 mutation 0 · 입력만으로 판정) → isolated unit test 가능. 기존 guard(scripts/start_task_guard.py 등) **직접 수정 0**. Layer A / NO-CRON: cron 0, subprocess 0, merge 0. ) annotationsN) dataclassfield)ListOptionalz dispatch.anu_finish_preflight.v1z .worktreesz task-(\d+)z^(?:-r(\d+)|\+(\d+))z^-(dev\d+|[a-z][a-z0-9]*)$ceZdZUdZdZded<dZded<dZded<dZded<dZ d ed <e e Z d ed <e ddZy) BranchParseubranch/ref 에서 안전 추출한 task 정체성. base_task_id : revision/executor suffix 제거한 base (예: task-2731) revision : replacement revision 라벨 (예: r2 / +1) — 없으면 "" executor : executor 라벨 (예: dev6) — 없으면 "" full_task_ref : base + revision (lock/state 정체성 — 충돌 회피용. 예: task-2730-r2) is_revision : revision suffix 존재 여부 (True → base 단독 추출 시 dev1 충돌 위험) str base_task_idrevisionexecutor full_task_refFbool is_revisiondefault_factory List[str]reasonsc,t|jSN)rr selfs 4/home/jay/workspace/dispatch/anu_finish_preflight.pyokzBranchParse.ok>sD%%&&Nreturnr)__name__ __module__ __qualname____doc__r __annotations__r rrrrlistrpropertyrrrr r ,s\L#HcHcM3Kt4GY4 ''rr c Ht|xsdj}|s tdgS|jddd}tj |}|std|dgSd |j d}||jd }d}d}g}tj|} | rj| j dxs| j d } |jd rd | nd| }|| jd }|jd|d|d|r=tj|} | r| j d}n|jd||jd r|d|} n|jdr||} n|} t|||| t||S)ubranch/ref 문자열에서 task 정체성을 **안전 추출**한다(`-rN`/`+N` 인식). 예시: - ``task/task-2731-dev6`` → base=task-2731, executor=dev6, full=task-2731 - ``task-2731-r2`` → base=task-2731, revision=r2, full=task-2731-r2 (is_revision) - ``task-2730-r2`` → base=task-2730, revision=r2, full=task-2730-r2 (★ base 단독이면 dev1 task-2730 충돌 → full_task_ref 사용) - ``task/task-2730+1`` → base=task-2730, revision=+1, full=task-2730+1 - ``main`` / "" → ok=False (task ref 아님) lock/state 정체성은 **full_task_ref** 를 사용해야 revision 이 base 와 충돌하지 않는다(dev2 → dev1 state 충돌 방지).r u빈 branch — task ref 아님.)r/utask- 패턴 부재: u — task ref 아님.ztask-Nz-rr+urevision suffix 인식: u — base 단독(uN)은 원본 task state/lock 과 충돌 가능 → full_task_ref 사용 권장.u!잔여 suffix 미인식(무시): -)r r rrrr)r stripr rsplit _TASK_BASE_REsearchgroupend _REVISION_REmatch startswithappend _EXECUTOR_REr) branchssegmbaserestr rrrmatchrev_numematchfulls r parse_branchrDCs FLb!A $E#FGG ((3 2 CS!A &>sgEZ$[#\]] 1771:, D quuwx=DHHG   %F ,,q/4V\\!_$(OOD$9Qwi=7)}FJJLM"&xj0A$HF G  ##D) ||AH NN>thG H3q #   S !z" N  rc^eZdZUdZded<ded<ded<eeZded <ed d Z y ) WorktreeChecku%worktree path mismatch 판정 결과.rmismatchr expected_subpath actual_pathrrrc|j Sr)rGrs rrzWorktreeCheck.oks==  rNr rr r!r"r#rr$rr%rr&rrrFrFs7/Nt4GY4 !!rrFr c`|s|n|d|}tjjt|S)u기대 worktree 상대경로: ``.worktrees/[-]``. 예: task_ref=task-2731, executor=dev6 → ``.worktrees/task-2731-dev6``.r.)ospathjoin WORKTREES_DIR)task_refrnames rexpected_worktree_subpathrSs-$8H:Qxj)AD 77<< t ,,r)r code_rootc Dt||}tjjt |xsd}g}tjj |}tj tztj z|tj zv}|xrF|jtj |zxs"tjj ||k(} |xr| } | r|s |jdtd|d|dn7| s5|jd|dtjj |d|rP|tjj|k(r.|jd|dn|jd |d |d t| ||| S) uj실 작업 경로가 기대 worktree(`.worktrees/[-executor]`)인지 판정. dev2 마찰: executor 가 CODE_ROOT 에 직접 체크아웃(`.worktrees/...` 미사용) → start_task_guard 기대 경로 불일치로 finish 미완. 본 함수는 그 mismatch 를 preflight 에서 탐지한다(경고/차단 판정). 파일시스템 mutation 0.r u!worktree mismatch: 실 경로가 uE/ 하위가 아님 (CODE_ROOT 직접 체크아웃 의심) — 기대=u , 실제=.u@worktree mismatch: worktree 이름 불일치 — 기대 segment=uM★ 실 경로 == CODE_ROOT — dev2 와 동일 마찰(직접 체크아웃). u 형태 worktree 분기 필요.z worktree OK: u 이(가) 기대 worktree(u ) 와 일치.)rGrHrIr) rSrMrNnormpathr basenameseprPendswithr8rF) rIrQrrTexpectedactualr expected_name in_worktrees name_matchrGs rdetect_worktree_mismatchr`s)8> NN_*;=  vh.H R_`a !  rc^eZdZUdZded<ded<ded<eeZded<ed d Z y ) TaskLockBypassuFtask-lock 마찰 우회 판정 결과(result.json 수거 lock 독립).r bypass_oklock_contendedresult_json_presentrrrc|jSr)rcrs rrzTaskLockBypass.oks ~~rNrrKr&rrrbrbs7POt4GY4 rrbF)rd lock_pathcg}|s |jdtd|d|S|r|jd|xsddn|jdtd|d|S) uOS runner 의 result.json 수거가 task-lock 마찰과 **독립**임을 판정한다. dev2 마찰: task-lock 생성/요구가 worktree 경로·tracked 여부에 묶여 finish 끝단이 막힘 → callback 미발사. 본 모듈은 result.json 수거 경로가 lock 과 **무관**(lock-free) 임을 명문화한다: - result.json 존재 → lock 마찰 여부와 무관하게 수거 가능(bypass_ok=True). - lock 이 contended 여도 result.json 수거/closeout/callback launch 는 진행 (OS runner 는 lock 을 잡지 않는다 — ANCHOR-1). - result.json 부재 → 수거 대상 없음(bypass_ok=False, 단 lock 과 무관한 사유). 파일시스템 mutation 0 · lock acquire 0 (판정만).ufresult.json 부재 — 수거 대상 없음(lock 과 무관). executor 미작성 또는 경로 오류.F)rcrdrerutask-lock 마찰 감지(lock=unknownuu) — 그러나 OS runner 의 result.json 수거는 lock-free(lock 독립). 수거·closeout·callback launch 진행.uJtask-lock 마찰 없음 — result.json 수거 진행(lock 독립 경로).T)r8rb)rerdrgrs rassess_task_lock_bypassrjs$G  t ) %   +I,B+CDf f  X  %   rcheZdZUdZded<ded<ded<ded <ee Zd ed <edd Z y)FinishPreflightuBfinish/closeout preflight 통합 결과(판정만 — mutation 0).r schemar r:zOptional[WorktreeCheck]worktreezOptional[TaskLockBypass] lock_bypassrrrc\t|jxr|jjS)uOS runner 가 result.json 을 수거 가능한가. worktree mismatch / branch revision / lock 마찰이 있어도 result.json 존재 시 수거 가능(ANCHOR-1) — lock_bypass.bypass_ok 가 단일 게이트.)rrorcrs r collectiblezFinishPreflight.collectibles& D$$C)9)9)C)CDDrNr) rr r!r"r#rr$rr%rqr&rrrlrl s?L K %%))t4GY4 EErrl)rIrrTrerdrgc t|}|xs |j}|jxs |j} d} |r| rt || ||} t |||} g} |j r9| jd|jd|jd|jd| r| jr| jdtt|| | | S) ubranch 안전 추출 + worktree mismatch + task-lock 우회 통합 판정. ★ 핵심 불변: worktree mismatch/branch revision/lock 마찰은 **수거를 막지 않는다**. 이들은 경고(reasons)로 surface 하되, result.json 이 존재하면 OS runner 가 수거하여 callback launch 를 강제한다(finish-task 끝단 마찰과 callback 발사의 분리 — ANCHOR-1).N)rQrrT)rerdrgzbranch revision(u#) — lock/state 는 full_task_ref=u 사용(base u 단독 시 충돌).uTworktree mismatch 경고 — 단 result.json 수거는 lock/worktree 독립(진행).)rmr:rnror) rDrrr r`rjrr8r rGrlPREFLIGHT_SCHEMA) r:rIrrTrerdrgbp exec_labelrQwtlbrs r preflightrxs f B(R[[J22??H"&Bx % (Z9  !/% B G ~~r{{m+N boo->>R T  bkkmn   r) rsrPr rDrFrSr`rbrjrlrx)r:r rr )r )rQr rr rr ) rIr rQr rr rTr rrF)rerrdrrgr rrb)r:r rIr rr rTr rerrdrrgr rrl)r" __future__rrMre dataclassesrrtypingrrrsrPcompiler1r5r9r rDrFrSr`rbrjrlrx__all__r&rrrs&# (!6  =) rzz12 rzz78  '' ',?F  ! !  !- 000 0  0  0h      ! +++ +  +^ EE E( % . .. .  .  ....b r