3j^dZddlmZddlmZmZddlmZddlm Z m Z m Z ddl m Z mZddlmZmZmZddlmZmZmZdd lmZmZdd lmZmZmZmZmZdd l m!Z!m"Z"m#Z#d Z$d Z%dZ&dZ'dZ(dZ)dZ*dZ+eGddZ,eGddZ-eeddd ddZ.dddddddddeeedddd d dZ/ d!dZ0gdZ1y)"uZ anu_v3.cancel_on_success_live_wiring — cancel-on-success LIVE integration. task-2553+45 (회장 지시 2 §1~§3). Strict-additive 신규 모듈. 문제 (회장 §2 verbatim): +41 / +39 는 normal completion callback 이 성공하고 collector adjudication 도 끝났지만, fallback/dead-man cron 이 뒤늦게 발화했다. 이는 중복 fallback 이 안전하게 무시된 사례일 뿐 cancel-on-success **live remove 성공** 사례가 아니다. +37 에서 wiring 은 mock/격리 검증됐으나, 실제 live normal collector path 가 fallback_cron_id 를 **durable** 하게 lookup 해 seam 을 경유하도록 결선되지 않았다(세션 불연속 — one-shot cron auto-delete + spawn 분리). 목표 (회장 §3 verbatim): 실제 normal collector 경로가 ``operational_collector_wiring::run_operational_completion_callback_collector`` 를 경유하게 한다. normal collector durable-success 후 ``run_operational_cancel_seam(operational=True)`` 1회. fallback_cron_id 는 **durable 4-tuple registry(+44)** 에서 lookup 한다. binding 부재면 cron-remove 0·fallback 보존. live cron-state verifier 5조건 AND PASS 일 때만 bound fallback 1건 제거. mismatch/missing → cron-remove 0. cancel -audit JSON 생성. cron-remove 실패/skip/exception 이 normal collector success 를 실패로 바꾸지 않게 decouple. 결선 (9-R.1 2-layer): * Layer A — 본 모듈은 cron 을 자체 로직으로 추가/제거하지 않는다. durable registry(+44) read-only lookup + artifact root(+46) read-only resolve + +37 standard wired entrypoint **경유**(이미 +25 → +23 seam → live verifier 5조건 → +9a remover 로 결선됨). ZERO ``cokacdir``/ ``subprocess`` exec. 테스트는 Fake/Spy 격리, 실 운영 cron 무접촉. * Layer B — cron-remove 대상은 (i) +44 durable registry 에서 안전 lookup 된 fallback_callback_cron_id 1건, (ii) registry record 의 chat/role 정합, (iii) +23 live cron-state verifier 5조건 AND PASS — 이 단일 bound·verified 1건만. 본 task 의 목표 자체(회장 §1). 선행 게이트 (회장 §4 / 9-R.1): fallback_cron_id 를 durable registry 에서 **안전 lookup** 할 수 없는 상태에서는 live cron-remove 를 시도하지 않는다(보존). 본 모듈은 +44/+46 산출물을 read-only/additive 재사용한다 (원본 무변). ) annotations) dataclassfield)Path)CallableOptionalUnion)canonical_root resolve_roots)NO_LEDGER_RECORDCallback4TupleRegistrydefault_ledger_path)build_cancel_on_success_auditguaranteed_write_auditnormalize_audit) ANU_CHAT_ID FALLBACK_ROLE) CallbackInputClassificationPostResultReview no_real_codex_post_result_review!run_completion_callback_collector)NormalCallbackBindingWiredCollectorResult.run_wired_normal_completion_callback_collectorz task-2553+45LOOKUP_VERIFIEDLOOKUP_NO_LEDGER_RECORDLOOKUP_NO_FALLBACK_BOUNDLOOKUP_TRACK_MISMATCHLOOKUP_CHAT_MISMATCHLOOKUP_ROLE_MISMATCH LOOKUP_ERRORceZdZUdZded<ded<ded<ded<ded <ded <d Zded <d Zded <d Zded<d Zded<dZ ded<ddZ y )DurableFallbackLookupudurable 4-tuple registry lookup 결과 (Layer B 안전 lookup). ``ok=True`` AND ``status==LOOKUP_VERIFIED`` 일 때만 binding 진행. 그 외 모든 경로(no record / no fallback / track·chat·role mismatch / error) → cron-remove 0, fallback 보존(회장 §3). boolokstrstatustask_id Optional[str]fallback_cron_iddispatch_cron_idnormal_collector_cron_idNchat_idrole ledger_pathr reasonc d|j|j|j|j|j|j |j |j|j|j|jd S)Nz'task-2553+45.durable_fallback_lookup_v1) schemar&r(r)r+r,r-r.r/r0r r2 r&r(r)r+r,r-r.r/r0r r2)selfs ;/home/jay/workspace/anu_v3/cancel_on_success_live_wiring.pyto_dictzDurableFallbackLookup.to_dict~sf?''kk|| $ 5 5 $ 5 5(,(E(E||II++"11kk  )returndict) __name__ __module__ __qualname____doc____annotations__r.r/r0r r2r8r9r7r$r$isa H K L####++!G]!D-!%K%$(NM(FC r9r$ceZdZUdZded<ded<ded<ded<ded<ded <ded <d ed <d ed<ded<dZded<dZded<eeZ ded<y)CancelOnSuccessLiveResultulive cancel-on-success wiring 1회 실행 결과. ``collector_result`` 는 +37/+25 가 반환한 값 그대로(디커플 — registry lookup / seam / cron-remove 결과로 변경 0). r%durable_successr$lookup&wired_via_operational_collector_wiring seam_invokedcron_remove_invokedfallback_preservednormal_success_unchangedr'event_idr; cancel_auditr*cancel_audit_pathNzOptional[object]collector_resultzOptional[WiredCollectorResult] wired_result)default_factorylistnotes) r<r=r>r?r@rNrOrrQrRrAr9r7rCrCsj  !!,00""M$$)-&-37L07-E4-r9rCN)expected_chat_id expected_roler0 autoset_cwdct|}t}| t|n t|} t |}|j ||} |j |} | | tk(r+tdt|dddt||jd S| dk(s| j|k7rUtdt|d| j| j | j"| j$t||jd St| j"t|k7rftdt&|d| j| j | j"| j$t||jd | j"d |d  S| j$xsd|k7rftdt(|d| j| j | j"| j$t||jd| j$d|d  S| j*sUtdt,|d| j| j | j"| j$t||jd Stdt.|| j*| j| j | j"| j$t||jd S#t$r8} tdt|dddt||jd|  cYd} ~ Sd} ~ wwxYw)u+44 durable 4-tuple registry 에서 fallback_cron_id 안전 lookup. 회장 §3/§4: fallback_cron_id 를 **durable** 하게 lookup 하지 못하면 (no ledger record / no fallback bound / track·chat·role mismatch / error) live cron-remove 를 시도하지 않는다 — 보존. +46 canonical-first 로 ledger root 를 resolve 한다 (autoset-cwd 단독 false-negative 금지 — +39 계열 원인 해소). )rUN)r)expected_task_idFu:durable registry lookup 예외 → 보존, cron-remove 0: ) r&r(r)r+r,r-r0r r2udurable 4-tuple ledger 에 record 부재 → fallback_cron_id 안전 lookup 불가, cron-remove 0, fallback 보존 (회장 §4)TRACK_MISMATCHuddurable record track mismatch (task_id) → unrelated cron 미인용, cron-remove 0, fallback 보존r5zdurable record chat_id=z != ANU u# → cron-remove 0, fallback 보존r1zdurable record role=z != udurable record 에 fallback_callback_cron_id binding 부재 (no_fallback 계약) → cron-remove 0, fallback 보존 (회장 §3)Tu>durable 4-tuple registry lookup 성공 — bound fallback 1건)r r rrr classify latest_for Exceptionr$r"r'r rr)rr,r-r.r/r r!fallback_callback_cron_idrr) r)rSrTr0rUrootscrootlpregistryverdictrecexcs r7%lookup_fallback_from_durable_registryrds " k 2E  E  " [  '  )"- ##$$ !!'* {g!11$*!!%)B //T  ""ckkW&<$(! 11%(%A%AKKB //<  $ 3;;3/00$'! 11%(%A%AKKB //)#++h#$$GI  $ B=($'! 11%(%A%AKKB //&sxxl$}6GH11  $  ( ($+! 11%(%A%AKKB //W  " ! 66--!$!=!= XXG++O  S   $!!%)B //OPSuU    s/J>> K?-K:4K?:K?)r0rUrM cron_listerremoverfallback_cancelled_marker_pathcancel_lock_pathseam_audit_pathcallback_contractrSrTpost_result_review_fnduplicate_callback_seenevidence_pathspost_result_review_marker_pathct|}t|j||||}|js*|jxsd}t ||||||}t |jtjk(xr|jduxr|jdu}|jd|d|j}tt||j||jddd|jd|j |j"dd g ||j| }t%||| | }t'||ddddd||||d d|jd|jdg St)|j|j*xsd|j,|jt/|}t1||||t|t|t||| | | | ||}|j2r|j2j4nd } d }!d}"d}#| Q| j6xsi}$|$j9d}!| j:xsd}%|%dv}#| j<r| j>rdnd}"tt|j@|j|jxsdtB|jD| rt | j<nd|"| rt | j>nd|!| r | jFnd|#|j |j"ddg|j@|j|jxsd }t%||| |j@ }t |jHjtjk(xr2|jHjduxr|jHjdu}t'|||jJ|jD|j<|jLd|j@|||jH|ddg S)u{live cancel-on-success wiring 진입점 (회장 §3 결선). 절차: 1. +44 durable 4-tuple registry 에서 fallback_cron_id 안전 lookup (+46 canonical-first root). lookup 불가/mismatch/no-binding → seam 미진입, cron-remove 0, fallback 보존, cancel-audit 기록. 2. lookup VERIFIED → durable record 의 4-tuple 로 ``NormalCallbackBinding`` 구성. 3. +37 ``run_wired_normal_completion_callback_collector`` **경유** (PRIMARY — 이미 +25 → +23 seam(operational=True) 1회 → live cron-state verifier 5조건 AND → bound fallback cron-remove). 4. cancel-audit JSON 생성·보장 기록. seam/cron-remove 의 어떤 예외· skip·실패도 collector_result 를 변경하지 않는다 (디커플 — +37/+25 권위 그대로 + 본 모듈도 collector_result 무변 반환). )r)rSrTr0rUz )rkrlrmrnT|F NOT_ATTEMPTEDusdurable 4-tuple registry lookup 불가/mismatch → seam 미진입, cron-remove 0, fallback 보존 (회장 §3/§4)u=디커플: lookup 실패는 normal collector 성공과 무관) rKr)target_cron_id lookup_statusrGremove_attempted remove_result skip_reasonalready_removed_or_missingr r0rR)rKr)rr) claim_dirrMrKNzdurable lookup z: ucallback mandatory rule 유지: lookup 실패에도 normal completion collector 1회 실행(frozen byte-0) — seam/cron-remove 만 skip (회장 §3, Codex HIGH 수용)) rDrErFrGrHrIrJrKrLrMrNrOrRr1)r)r,r-r+r.) bindingdispatch_fired_marker_pathresult_json_path report_pathcollector_result_marker_pathrxrerfrgrhrirjchecks)SKIP_LIVE_SKIP_ALREADY_REMOVEDSKIP_LIVE_SKIP_ALREADY_FIREDSKIP_LIVE_SKIP_NOT_FOUND CANCELLEDREMOVE_NONFATALulive collector path → durable 4-tuple registry lookup → +37 wired entrypoint → +25 → +23 seam(operational=True) → live verifier 5조건 → bound fallback cron-removeui디커플: seam/cron-remove 결과와 무관하게 collector_result 불변, normal_success_unchanged=True)rKr)rrrsrGrtrufallback_cancelledfive_condition_resultsrvrwr r0rRuzCOLLECTOR_PATH live-wired: durable 4-tuple registry lookup (+44) + canonical-first root (+46) → +37 → +25 → +23 seamuLayer A: 본 모듈 임의 cron 조작 0 / Layer B: durable lookup + 5조건 verified single bound cancel 1건 (회장 §1 목표 자체))'rrdr)r&r+rr%classificationrPASScloseout_candidate ack_acquiredr(rrr2r r0 _write_auditrCrr,r-intr wiring_result seam_outcomelive_verificationgetseam_classificationrHrrKrrGrvrNrFrI)&inpack_pathrzr{r|r}rxr0rUrMrerfrgrhrirjrSrTrkrlrmrndfmrEtargetrNrDrKaudit audit_writtenrywiredsofiverualreadylvscs& r7!run_cancel_on_success_live_wiringrAs?T ) *C 2 )# F 99((7K<  "7$;)+I    + +~/B/B B 6 33t; 6 --5  {{m1VHAfmm_ 5  )! %$mm"!&-"MM+0%44"..VS $KK!+ .% Y:K )+37 %#%)+-!&--6==/BG  ,$ 006B!'!@!@00$% G ; #&./%%)*F%G'E)'+ E$.3-@-@   ) )dB D#MG ~  ! ! 'Rvvh  # # )r    ! !!44 :K  %^^KK!228b)++=?T""8"89U'/1R**+u#'+-2'.!00**K8 ! 0 ..4"7 E:! 6GM  --1D1DD 8  " " 5 5 = 8  " " / /4 7O %'  8 8''!55 33!%'// N U  r9c | t|nt|tdz }djd|Ddd}t||t|td|dz gS) u?cancel-audit 다중 후보 보장 기록 (Layer A — NO-CRON).Nz.cancel-audit.jsonr1c3DK|]}|jr|ndyw)_N)isalnum).0cs r7 z_write_audit..7sCQAIIKqS0Cs Pz.cancel-audit.z.json)primary fallbacks)rTASK_MARKER_PREFIXjoinr)rrxrMrKrsafe_eids r7rr*s  (  )_"4!55GH H wwC(CCCRHH !  O#$N8*EB C  r9) rrrrrr r!r"r$rCrdr) r)r'rSUnion[int, str]rTr'r0Optional[Union[str, Path]]rUrr:r$).rrrUnion[str, Path]rzrr{rr|rr}rrxrr0rrUrrMrrezOptional[Callable[[], dict]]rfzOptional[Callable[..., object]]rgrrhrrirrjzOptional[dict]rSrrTr'rkz2Callable[[dict, Classification], PostResultReview]rlOptional[list]rmrrnrr:rC) rr;rxrrMrrKr'r:r*)2r? __future__r dataclassesrrpathlibrtypingrrr anu_v3.artifact_root_resolverr r anu_v3.callback_4tuple_registryr r ranu_v3.cancel_audit_writerrrrutils.live_cron_state_verifierrr(utils.anu_delegation_completion_callbackrrrrr5utils.normal_completion_callback_collector_entrypointrrrrrrrrr r!r"r$rCrdrr__all__rAr9r7rsu&N#(,,  $$35/--  " "  " J .. .2)4&.2.2 X X&X X , X , XXH/3.24804/3AE3726(,(3& ).2%)AE3f ff!1 f ' f " f#3f f,f,f2f.f-f%?f1f 0!f"&#f$&%f&'f()f.,/f0#1f2%?3f45fR  2     0 r9