j UdZddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z m Z ddl m Z ddlmZddlmZmZmZdd lmZmZmZd Zd Zd Zd ZdZdZdZded<dZ ded<e!ee zZ"ded<ejFdZ$d=dZ%Gdde&e Z'Gdde&e Z(Gdde)Z*Gdd e)Z+eGd!d"Z,eGd#d$Z-eGd%d&Z.eGd'd(Z/d>d)Z0dd* d?d+Z1eGd,d-Z2 d@d.Z3dAd/Z4dBd0Z5dBd1Z6dBd2Z7dCd3Z8ded4 dDd5Z9 dEd6Z:dFd7Z;ddd8 dGd9Zy)Iu utils/anu_delegation_completion_callback.py — task-2595 Phase 2 구현. ANU_DELEGATION_COMPLETION_CALLBACK 의 실행 코드 (fixture/mock 검증 한정). Phase 1 LOCKED spec: memory/tasks/task-2595.md (locked content sha256 = c151030d719762da35eb5cafc34a9f4c74df4ba4c5085e077bb109120ae050d5, post-lock metadata annotation sha256 = 4ee97a3bfb2884535c172b8a69b95ec6199353e5bf89e67115732bc61d86dd1d — LOCK 권위는 locked content hash 에 귀속, task-2595.spec-lock.json 참조). 본 모듈은 spec §3~§10 정의를 코드로 구현한다: * §3 anu_delegation_result_v1 schema + validation * §4 completion_callback_contract_v1 schema + validation * §5 callback_ack_dedupe_v1 schema + validation * §6 dual callback (normal completion + fallback stale) 모델 * §7 dedupe / ack single-winner (atomic O_CREAT|O_EXCL) * §8 ANU-Codex post-result review hook (advisory, bounded loop 패턴 재사용) * §9 상태 분류 7종 + 분류 우선순위 (inference drift 0 — evidence 필드 기반) * §10 callback 실행 시 검증 항목 경계 (회장 Phase 2 §1~§3 verbatim): * **fixture/mock 기반 구현 검증까지로 제한**. 실제 callback 운영 활성화 / 실제 dev bot callback 등록 / 실제 fallback stale callback 등록 금지. * watcher / polling loop / daemon / systemd 상시 감시 0 — collector 는 one-shot 함수 호출이며 내부 루프·sleep·스케줄러 없음. * 자동 closeout 권한 미부여 (회장 §5). collector 는 수집·검증·분류 + closeout *candidate* 만 생성. 실제 closeout / finish-task.sh / manual .done 호출 없음. * post-result review hook 의 기본 invoker 는 실제 codex 를 호출하지 않으며 ``NoRealCodexReviewError`` 를 raise 한다. 검증은 mock invoker 로만. 이 파일은 신규 파일이며 forbidden_write_targets (dispatch.py / scripts/finish-task.sh / task-timer.py / post-tool-use.sh / utils/anu_codex_bounded_loop.py / replacement_pr_dry_run_* / test_anu_codex_bounded_loop_2592.py / test_task_2591_dry_run_activation_harness.py / task-2591.md / task-2592.md / task-2595.md) 를 일절 수정하지 않는다. Critical 7 분류는 utils.anu_codex_bounded_loop 를 read-only import 로 재사용한다 (spec §9 priority 4 — feedback_critical_escalation_only_260508 7종 동일). ) annotationsN) dataclassfield)datetimetimezone)Enum)Path)CallableOptionalUnion)Signalsany_critical_7critical_7_hitsanu_delegation_result_v1completion_callback_contract_v1callback_ack_dedupe_v1 lL5:)normal_callback_registerednormal_callback_cron_idfallback_firedttl_expiry_ts_utc ttl_exceededbot_liveness_signalbot_liveness_observedtuple[str, ...]$STALE_DISTINCTION_EVIDENCE_SPEC_KEYS)evidence_collection_failed+STALE_DISTINCTION_EVIDENCE_OPERATIONAL_KEYSzfrozenset[str]'STALE_DISTINCTION_EVIDENCE_ALLOWED_KEYSz^[\w./+\-]+\.json$cf|yt|tsyttj |S)uspec §3 — ``codex_post_result_review_ref`` 계약 검사. True 조건: ``None`` (null) **또는** ``.json`` 으로 끝나는 marker path 문자열(공백/괄호/'=' 등 status 문자열 토큰 불포함). 그 외 모두 False. TF) isinstancestrbool_MARKER_PATH_REmatch)values ?/home/jay/workspace/utils/anu_delegation_completion_callback.pyis_marker_path_or_nullr)os/  } eS ! %%e, --c,eZdZdZdZdZdZdZdZdZ dZ y ) Classificationu?spec §9 — delegation completion callback 결과 분류 7종.PASSHOLD_FOR_CHAIR BOT_STALERESULT_MISSINGCALLBACK_MISSING CRITICAL_7DUPLICATE_CALLBACK_IGNOREDN) __name__ __module__ __qualname____doc__r-r.r/r0r1r2r3r*r(r,r,s*I D%NI%N)J!=r*r,ceZdZdZdZdZy) CallbackTypeuspec §3/§6 — dual callback.normalfallback_staleN)r4r5r6r7NORMALFALLBACK_STALEr8r*r(r:r:s) F%Nr*r:ceZdZdZy)NoRealCodexReviewErroru기본 post-result review invoker 호출 시 raise. Phase 2 는 fixture/mock 검증 task이므로 실제 codex:codex-rescue 를 호출하지 않는다 (회장 Phase 2 §1 verbatim). 실 검토가 필요하면 명시적 mock/실 invoker 를 주입한다. Nr4r5r6r7r8r*r(r@r@r*r@ceZdZdZy)!RealCallbackRegistrationForbiddenu"실제 callback cron 등록 시도 시 raise. 회장 Phase 2 §3 verbatim — 실제 dev bot callback / fallback stale callback 등록 금지. 본 모듈은 cron 을 등록하지 않으며, 등록 시도 경로는 명시적으로 차단한다 (fixture/mock 검증 한정). NrAr8r*r(rDrDrBr*rDceZdZUdZdZded<dZded<dZded<dZded <dZ ded <d Z d ed <dZ ded<dZ ded<y)StaleDistinctionEvidenceu spec §3 ``stale_distinction_evidence`` 블록. spec §9.2 결정 규칙은 **이 필드들만** 근거로 한다 (inference drift 0): * normal_callback_registered == false AND bot_liveness_observed == false → BOT_STALE * normal_callback_registered == false AND bot_liveness_observed == true → CALLBACK_MISSING * 두 신호 모두 판정 불가 (evidence_collection_failed) → HOLD_FOR_CHAIR 허용 key 집합은 모듈 상수 ``STALE_DISTINCTION_EVIDENCE_ALLOWED_KEYS`` (spec §3 7 key + 운영 필요 ``evidence_collection_failed``)로 **명시 정의**되며, ``validate_delegation_result()`` 가 (a) spec §3 7 nested key 전수 존재 (b) 허용 집합 외 key 거부 를 검증한다 (task-2595_2+1 항목 2/3). Fr$rN Optional[str]rrrrnoner#rrr) r4r5r6r7r__annotations__rrrrrrrr8r*r(rFrFs_"(-,-1]1 ND '+}+L$%%"'4'',,r*rFceZdZUdZdZded<dZded<dZded<dZded<dZ ded<dZ ded <dZ ded <d Z d ed <d Z d ed<dZded<ddZy)ForbiddenActionPostchecku/spec §3 ``forbidden_action_postcheck`` 블록.rintcommitpushpr_openmerge github_writereal_write_mode auto_restoreFr$finish_task_sh manual_doneforbidden_write_targets_changedcN|jdkDxs|jdkDxs|jdkDxss|jdkDxsb|jdkDxsQ|j dkDxs@|j dkDxs/|jduxs|jduxs|jdkDS)NrT) rMrNrOrPrQrRrSrTrUrV)selfs r(violatedz!ForbiddenActionPostcheck.violateds KK!O 8yy1} 8||a 8zzA~ 8  1$ 8 ##a' 8   1$ 8""d* 84' 833a7 r*N)returnr$)r4r5r6r7rMrIrNrOrPrQrRrSrTrUrVrYr8r*r(rKrKsl9FCOD#MGSE3NL#OSL# ND K+,#S,  r*rKc2eZdZUdZded<ded<ded<ded<ded<d Zded <d Zded <d Zded<ee Z ded<ee Z ded<ee Zded<eeZded<dZded<ee Zded<eeZded<d Zded!<y")# CallbackInputu-delegation completion callback 1회 입력 (one-shot, 루프 없음). 모든 필드는 fixture/mock 으로 주입된다. 본 모듈은 실제 cron-history / marker filesystem 을 watcher/polling 으로 감시하지 않는다 — 호출자가 수집한 스냅샷을 1회 전달한다. r#task_idexecutordispatch_cron_idr: callback_typecallback_cron_idok cron_status completed task_statusgfloatcron_duration_mindefault_factoryrFstale_distinction_evidence list[str]output_markerszdict[str, bool]required_closeout_markersrKforbidden_action_postcheckTr$ dev_sunsetzdict[str, str]preservation_anchorsr signalsF chair_gatedN)r4r5r6r7rIrcrergrrFrjlistrldictrmrKrnrorpr rqrrr8r*r(r\r\sLMK"K""u";@0< 8!&d ;NI;16t1LL;@0< 8J+0+F.FW5GW5Kr*r\ceZdZUdZded<ded<ded<ded<ded <ded <ee Zd ed <ee Zd ed<dZ ded<ee Z ded<y)CollectorResultucollector 1회 실행 결과.r,classificationrtdelegation_result ack_deduper$ ack_acquiredcloseout_candidatechair_report_requiredrhrkcritical_7_hit hold_reasonsNrGcodex_post_result_review_refclassification_evidence) r4r5r6r7rIrrsr}r~rrtrr8r*r(rvrv sb'"" %d ;NI;#D9L)926 -6$)$$?T?r*rvcftjtjj dS)Nz%Y-%m-%dT%H:%M:%SZ)rnowrutcstrftimer8r*r(_now_utcrs! << % . ./C DDr*)duplicate_callback_seenc t|}|jjddtt |t ||j |dt|xsgdd } tjt |tjtjztjzd}tj0|dd5} tj2|| dd | j5tj6| j9d d d d|fS#t$ri} tj|j!d}n#t"t$f$ri}YnwxYw|j'd tt|j)d g} || vr| j+|| |d <d|d <d |fcYSt"$r,} | j,t,j.k(r d |fcYd } ~ Sd } ~ wwxYw#1swYd|fSxYw)uspec §7 — ack marker atomic single-winner. ``os.open(O_CREAT|O_EXCL|O_WRONLY)`` 로 ack marker 생성 시도. * 성공 (부재) → ack 기록 후 ``(True, ack_dict)``. result collection 진행. * 실패 (이미 존재 → ``FileExistsError``) → ``(False, ack_dict)``. 후발 callback 은 DUPLICATE_CALLBACK_IGNORED 후 즉시 종료 (idempotent). normal/fallback 경합 시에도 atomic create 가 single-winner 를 보장한다. Tparentsexist_okzO_CREAT|O_EXCLu5DUPLICATE_CALLBACK_IGNORED (idempotent 즉시 종료)) schemats_utcr]ack_marker_pathwinning_callback_typewinning_callback_cron_idatomic_create_methodrduplicate_resolutioniutf-8encodingrrrFNwindent ensure_ascii)r parentmkdirSCHEMA_CALLBACK_ACK_DEDUPErr#r'rsosopenO_CREATO_EXCLO_WRONLYFileExistsErrorjsonloads read_textOSError ValueError setdefaultgetappenderrnoEEXISTfdopendumpflushfsyncfileno) ack_pathr]rrrpathackfdexistingseenexcfs r(try_acquire_ackr s$ >DKKdT2,*t9!6!g}|jdtk7r|jdt|t|dz }|jd}|J|tj j tjj fvr|jd||jd}|4|tDchc]}|j c}vr|jd|d|vr0|jd}t|s|jd |d |vrp|jd }t|ts|jd |S|tDcgc] }||vrd | c}z }||Dcgc]}|tvrd |c}z }|Scc}wcc}wcc}w)uMspec §3 anu_delegation_result_v1 구조 검증. errors 빈 리스트 = PASS.rschema!=)rr]r^r_r`rarcrergrjrlrmrnrorprrwevidence_pathsrr`zcallback_type invalid:rwzclassification invalid:rz5codex_post_result_review_ref:not_marker_path_or_null:rjz%stale_distinction_evidence:not_a_dictz#stale_distinction_evidence.missing:z+stale_distinction_evidence.unspecified_key:)rSCHEMA_DELEGATION_RESULTrrr:r=r'r>r,r)r"rtrr )rerrorsctclscrefsders r(validate_delegation_resultrsFuuX22 !9 :;< h  F0  B ~"!!##))%  .rd34 %% !C 3&G1qww&GG /u56&*ee23%c* MMG'  $q(ee01#t$ MMA B M =C<6aS9 F CC>aSA F M='H& s;FF5FcTg}|jdtk7r|jdt|t|dz }|jdtk7r*|jdtd|jd|jddur|jd |S) uspec §4 completion_callback_contract_v1 구조 검증. 회장 §3 verbatim — dispatch.py 미수정. ``dispatch_py_untouched`` 가 True 가 아니면 contract 위반. rr)callback_chat_idcallback_key_ref"callback_register_command_templateregister_timingregister_failure_fallbackdispatch_py_untouchedrzcallback_chat_id!=:rTu/dispatch_py_untouched must be true (회장 §3))r#SCHEMA_COMPLETION_CALLBACK_CONTRACTrrANU_CALLBACK_CHAT_IDrrs r(%validate_completion_callback_contractrs FuuX== !D EFG h    F uu  $88  !5 6a>P8Q7R S  uu $%T1 GH Mr*cg}|jdtk7r|jdt|t|dz }|S)u.spec §5 callback_ack_dedupe_v1 구조 검증.rr)rr]rrrrrr)rrrrrs r(validate_callback_ack_dedupersMFuuX44 !; <=> h    F Mr*c6tt|dtdddddS)uspec §4 — dispatch prompt 에 봇이 등록할 normal completion callback contract 템플릿 생성. **실제 cron 을 등록하지 않는다** (schema 산출만). ucokacdir --cron " 완료. ANU result collector 실행: cron-history/marker/anchor 수집·검증·분류" --at "<즉시>" --chat z --key u-dev bot 정상 종료 직전 마지막 행동uP봇이 본 cron 등록 못하고 죽으면 §6 fallback stale callback 안전망T)rrrrrrr)rr)rs r("build_completion_callback_contractrs6 60, *++; =K ^!% r*)task_ttl_hoursttl_margin_minc2||nt}||dzz|dzzS)uspec §14 / 회장 §6 verbatim — fallback stale callback 발화 시각 계산. 기본 = dispatch_ts + bot_max_ttl + 10m. task별 TTL 명시 시 = dispatch_ts + task_ttl + 10m. **계산만 한다 — 실제 cron 을 등록하지 않는다** (회장 Phase 2 §3). g @gN@)DEFAULT_BOT_MAX_TTL_HOURS)dispatch_ts_epochrr ttl_hourss r(compute_fallback_stale_at_epochr s0)4:S y61 1NT4I IIr*cd|j|j|j|jd}|jrd|d<tj |fS|jdur%|jdurd|d<tj |fS|jdur%|jdurd|d<tj|fSd |d<tj |fS) uospec §9.2 결정 규칙 — 단일 분기 (추론 0, 필드 기반). 반환: (분류, evidence dict) u spec_§9.2)rulerrrru(evidence_undeterminable→HOLD_FOR_CHAIRbranchFu&no_normal_cb + no_liveness→BOT_STALETu*no_normal_cb + liveness→CALLBACK_MISSINGu(normal_cb_registered→not_fallback_only)rrrrr,r.r/r1)revs r(_classify_fallback_staler"s&)&D&D"66!$!:!:&)&D&D  B %%A8 --r22 %%.33L3LPU3U?8 (("-- %%.33L3LPT3TC8 //44=BxL  ) )2 ..r*cdgi}|djd|sd|d<tjgg|fS|j}|djd|jt j k(xr|jduxr|jdu}|rCt|\}}d|j|d<||d <|tjk(rd gng}||g|fS|djd |jjD cgc] \}} | dur| } }} | r/d |d<| |d <tj| D cgc]} d|  c} g|fS|djdt|j } t#|j rd|d<| |d<tj$g| |fS|djd|j&} |j(jDcgc] \}}|dk7s |}}}g}| j+r|jd|r#|jddj-|z|j.r|jd|j0dur|jd|rd|d<||d<tj|g|fSd|d<tj2gg|fScc} }wcc} wcc}}w)u spec §9 분류 우선순위 적용. 반환: (classification, hold_reasons, critical_7_hit, classification_evidence) 우선순위 (spec §9): 1. ack 이미 존재(중복) → DUPLICATE_CALLBACK_IGNORED 2. fallback-only fire + TTL 초과 → §9.2 BOT_STALE/CALLBACK_MISSING/HOLD 3. callback fire 했으나 필수 marker 부재 → RESULT_MISSING 4. Critical 7 hit → CRITICAL_7 5. forbidden action 위반 또는 chair-gated → HOLD_FOR_CHAIR 6. 전부 미해당 → PASS priority_checkedz 1:ack_dupz1:DUPLICATE_CALLBACK_IGNOREDmatchedz2:fallback_stale_distinctionFTz2:stale_distinction&fallback_stale_evidence_undeterminablez3:result_missingz3:RESULT_MISSINGmissing_required_markerszmissing_required_marker:z 4:critical_7z 4:CRITICAL_7r}z5:forbidden_or_chair_gatedr&#forbidden_action_postcheck_violatedzpreservation_anchor_mismatch:,rrdev_not_sunsetz5:HOLD_FOR_CHAIRr~z6:PASS)rr,r3rjr`r:r>rrrr'r.rmitemsr0rrqrr2rnrprYjoinrrror-)inprzevidencer fallback_onlyrsub_evreasonsnamepresentmissing_markersmc7facastatusanchor_mismatchr~s r(classifyr >s&)"-H  '' 4 <992r8LL ( (C  ''(FG \888 %  * *e 3 %    $ .s3 V "399+.(.$%n3336 6  Wb(++  ''(:;!::@@B D' $  O 0/>+,  ) )5D E's + E       ''7  %Bckk",%'!"))2r8<<  ''(DE ( (C3399;av?PO!L ||~AB +chh.G G  M* ~~T!,-0#/ --|RJJ#HY   R 22_ F sJ69 J<$ K2Krrclidtdtd|jd|jd|jd|j j d|jd|jd |jd |jd tj|jd t|jd t!|j"dtj|j$d|j&dt!|j(d||j t|xsg|dS)u5spec §3 anu_delegation_result_v1 marker dict 생성.rrr]r^r_r`rarcrergrjrlrmrnrorpr)rwrr)rrr]r^r_r`r'rarcrerg dataclassesasdictrjrsrlrtrmrnrorp)rrwrrrs r(build_delegation_resultrss * (*  3;;  CLL   C00   **00   C00  s  s  S22  %k&8&8  * *'   $s112  $T#*G*G%H  %k&8&8  * *' ! & cnn' ( S%=%= >) * '(D+ ,)..~34*1 r*)post_result_review_fnrrpost_result_review_marker_pathc Xt||j|j|j|\}}t ||\}} } } |s>t |||j dt|d|} t|| |dddggd|  Sd} d}t |||j dt||}d} |||}|jdurt| d gz} tj}|jdurt| d gz} tj}|r| t!|}n%t!|j"|jdz }|j"j%dddt'|j|j(t+|j,dt/j0|d}|j3t5j6|dddt|} nd} t |||j dt|| |} |tj8k(}|tj:tj<tjtj>tj@fv}t|| |d||| | | |  S#t$rd}td dddd }YwxYw)uspec §2 5~11단계 / §7 / §8 / §9 / §10 — one-shot 결과 회수. 호출 1회 = callback 1회. 내부에 루프 / sleep / scheduler / watcher 없음 (회장 §3 verbatim — long-running watcher / polling loop / daemon 금지). 절차: 1. (§7) ack atomic single-winner 시도. loser → 즉시 DUPLICATE 종료. 2. (§9) evidence 필드 기반 분류 (inference drift 0). 3. (§8) post-result review hook 실행 (advisory, 기본 invoker 는 실제 codex 호출 금지 — mock 주입 필요). 자동 closeout 권한 미부여. 4. (§3) anu_delegation_result_v1 marker dict 생성. 5. (§10) PASS → closeout *candidate* only (자동 closeout 권한 X). CRITICAL_7 / RESULT_MISSING / HOLD → 회장 보고 flag. )r]rrrrNr F) rwrxryrzr{r|r}r~rr)rTSKIPPED_NO_REAL_CODEXuq기본 invoker — 실제 codex 호출 금지 (회장 Phase 2 §1). mock 주입 시에만 advisory 판정 산출.)rrrrrz9BOUNDARY_VIOLATION:post_result_review_execution_performedz2BOUNDARY_VIOLATION:auto_closeout_authority_grantedz.post-result-review.jsonranu_post_result_review_v1)rrr]rwrrreviewrrrr)!rr]r`rar rrr#rvr@rrrsr,r.rr rrrr'r$rr r write_textrdumpsr-r2r0r/r1)rrrrrracquiredrrwr~c7_hitcls_evrx review_refrinterimreview_performedreview_marker_path review_markerr{r|s r(!run_completion_callback_collectorr s4$ !//!$!5!5 7 MHc4+>+>>*!!%%%%  '' / %+-3!%/ &  S "  !!+ %,1<    s2 J J)(J))r,r:r@rDrFrKr\rvrrrrDEFAULT_TTL_MARGIN_MINrrrrr r)rrrrrrrrr r )r'objectrZr$)rZr#) rUnion[str, Path]r]r#rr:rr#rOptional[list[str]]rZztuple[bool, dict])rxrtrwr,rZr)rrtrrrZrk)rrtrZrk)rr#rZrt)rrfrzOptional[float]rrLrZrf)rrFrZztuple[Classification, dict])rr\rzr$rZz1tuple[Classification, list[str], list[str], dict]) rr\rwr,rr#rrGrr$rZrt)rr\rr#rz2Callable[[dict, Classification], PostResultReview]rr$rr$rzOptional[Union[str, Path]]rZrv)?r7 __future__rr rrrrerrrrenumrpathlibr typingr r r utils.anu_codex_bounded_loopr rrrrrr!rrrrIr frozensetr compiler%r)r#r,r: RuntimeErrorr@rDrFrKr\rvrrrrrrrrrrrr rr __all__r8r*r(r/s'R# (',, 6&G#5"9$o@+_;D(12;'"**23 . >S$ >&3&\  -- -<     @  B  @ @  @$E48 ;;;( ; " ; 1 ;;B    -;  "8BJ:*0'+0 JJ$J J  J*/ !/ /8\3N37*. " """" #0 " ( " "\ )37*.AE[ [[ [1[([%?[[| r*