3j~ dZddlmZddlmZmZddlmZddlm Z m Z m Z ddl m Z mZddlmZddlmZmZmZdd lmZdd lmZmZdd lmZmZd Zd ZdZdZ dZ!GddZ"GddZ#eGddZ$eGddZ%eGddZ&eGddZ'eGddZ(dd  d-d!Z)eed" d.d#Z*d/d$Z+d%d%d%d%d%eed&d'dd( d0d)Z, d1d*Z- d2d+Z.gd,Z/eZ0y%)3uanu_v3.cancel_on_success_live_e2e — cancel-on-success live remove END-TO-END. task-2553+48 (회장 결정, 코드/파일 자동화). Strict-additive 신규 orchestrator. 문제 (회장 §2 verbatim): +45 self-test 에서는 fallback binding 이 properly-bound 상태가 아니어서 ROLE_MISMATCH 로 fallback 보존이 발생했다. 따라서 cancel-on-success live remove 는 아직 end-to-end 실증되지 않았다. 목표 (회장 §1/§3 verbatim): properly-bound 4-tuple 기반 cancel-on-success live remove end-to-end 실증. 1. dispatch 시 +44 guard 가 normal_collector_cron_id + fallback_cron_id(role=fallback) 를 registry 에 정합 기록(REGISTERED), +47 ``write_back_completed`` 로 normal durable-success COMPLETED 갱신 → live cron id == ledger id 일치 보장. 2. 이 properly-bound 상태에서 +45 ``run_cancel_on_success_live_wiring`` 실행 → +37→+25→+23 cancel seam 1회 → live verifier 5조건 AND PASS → bound fallback cron 1건 실제 제거 → cancel-audit JSON 생성. 3. normal success 후 fallback 발화 0(실 제거 입증) end-to-end. 결선 (9-R.1 2-layer): * Layer A — 실 운영 cron 무접촉 (§5 구속). 본 모듈은 cron 을 자체 로직으로 추가/제거하지 않는다. ZERO ``cokacdir`` / ``subprocess`` exec. properly-bound 4-tuple 은 +44 append-only API + +47 write-back API (read-only/additive 재사용) 로만 구성하고, live cron 조회/제거는 전적으로 주입 Fake/Spy DI(전용 격리 fixture cron 세계)로만 수행한다. 실 운영 fallback cron 강제삭제 0. * Layer B — bound·verified single cancel (§3 목표 자체). properly-bound 4-tuple(live==ledger·role=fallback) + +45 live verifier 5조건 AND PASS = 단일 bound·verified cancel 1건 = 회장 §1 목표(end-to-end 실증) 그 자체. mismatch/missing/unverified = 보존·decouple(+45 보수 가드 무회귀). 무변 의무 (회장 §4/§6): +44/+45/+46/+47 모듈·+37/+25/+23·frozen anchor·기존 산출물 byte-0 /additive 무변. 본 모듈은 그것들을 read-only/additive 재사용하는 orchestrator 일 뿐이다 (신규 cancel 로직 0 — +45 권위 그대로 경유). ) annotations) dataclassfield)Path)ListOptionalUnion)Callback4TupleRegistry make_record)write_back_completed)LOOKUP_VERIFIEDCancelOnSuccessLiveResult!run_cancel_on_success_live_wiring)guaranteed_write_audit) ANU_CHAT_ID FALLBACK_ROLE) CallbackInputClassificationz task-2553+48z+task-2553+48.cancel-on-success-e2e-audit_v1E2E_PASS E2E_PRESERVED E2E_DECOUPLEDc8eZdZdZddZd dZd dZd dZd dZy) FakeCronWorldub전용 격리 fixture cron 세계 (실 운영 cron 무접촉, NO-CRON). ``entries`` 는 ``{id, task_id, chat_id, role, fired, removed}`` dict 리스트. 실 cokacdir/subprocess 를 절대 호출하지 않는다 — 본 task 의 e2e 실증은 이 격리 세계로만 수행한다(회장 §5 "live cron 강제삭제" 준수, Layer A). cf|Dcgc] }t|c}|_d|_d|_ycc}w)Nr)dictentries list_calls fire_attempts)selfres 8/home/jay/workspace/anu_v3/cancel_on_success_live_e2e.py__init__zFakeCronWorld.__init__hs,5<#=DG#= $>s.cV|jD]}|jd|k(s|cSy)Nid)rgetrcron_idr s r!_findzFakeCronWorld._findns/ AuuT{g% c|xjdz c_d|jDcgc] }t|c}ddidScc}w)u@+23 verifier 가 호출하는 격리 cron 조회 (실 조회 0).okfake_isolated_worldT)statusrraw)rrr)rr s r!listerzFakeCronWorld.listerts> 1)-6AQ6)40  6s?c6|j|}|yd|d<y)NFTremoved)r(r&s r! mark_removedzFakeCronWorld.mark_removed}s$ JJw  9) r)c|xjdz c_|j|}|"|jds|jdryd|d<y)uJnormal success **후** fallback 발화 시도 시뮬레이션. 실제 cron 이 제거됐으면(또는 부재) 발화 불가 → False. return True 는 fallback 이 실제로 발화함을 의미(회장 §3: end-to-end 에서 0 이어야 함). 실 cron 무접촉 — 격리 세계 상태만 평가. r+r2firedFT)rr(r%r&s r!attempt_fallback_firez#FakeCronWorld.attempt_fallback_firesL a JJw  9i(AEE'N' r)N)r List[dict]returnNone)r'strr8Optional[dict]r8r)r'r:r8bool) __name__ __module__ __qualname____doc__r"r(r0r3r6r)r!rr_s     r)rc,eZdZdZddd dZddd dZy) WorldSpyRemoveruB주입 fake remover — 실 cron 삭제 0, FakeCronWorld 상태만 변형. +45→+37→+25→+23→+9a 경로가 operational=True 로 호출(dry_run=False). 호출 인자를 spy 기록하고, 격리 세계의 해당 entry 만 removed 표시한다 (실 운영 cron 무접촉 — 회장 §5/9-R.1 Layer A). r2)r.c.||_||_g|_y)N)worldr.calls)rrFr.s r!r"zWorldSpyRemover.__init__s  !# r)T)dry_runcddlm}|jj||d|jdk(r|s|j j |||jd|jS)Nr) RemoverResult)r'rHr2zfake-isolated:)r.detail))utils.completion_callback_fallback_cancelrJrGappendr.rFr3)rr'rHrJs r!__call__zWorldSpyRemover.__call__sa  g'BC ;;) #G JJ # #G ,;; }'E  r)N)rFrr.r:)r'r:rHr=)r>r?r@rAr"rNrBr)r!rDrDs?H$ 9=  r)rDcfeZdZUdZded<ded<ded<ded<ded<ded<ded <eZded <y ) ProperlyBound4TupleuDdispatch 시 +44 guard 가 기록할 4-tuple (role=fallback 정합).r:task_id dispatch_iddispatch_cron_idexecutorchat_idnormal_collector_cron_idfallback_callback_cron_idroleN)r>r?r@rA__annotations__rrXrBr)r!rPrPs6N LM L!!""D#r)rPcreZdZUdZded<ded<ded<ded<d ed <ded <ee Zd ed<ddZy)BindingConstructionEvidenceuBproperly-bound 4-tuple 구성 증거 (+44 guard + +47 write-back).r=guard_registered_appendedr guard_recordr:writeback_statuswriteback_appendedr;completed_record ledger_pathdefault_factory List[str]reasonsc d|j|j|j|j|j|j t |jdS)Nz$task-2553+48.binding_construction_v1)schemar\r]r^r_r`rare)r\r]r^r_r`ralistrers r!to_dictz#BindingConstructionEvidence.to_dictsQ<)-)G)G -- $ 5 5"&"9"9 $ 5 5++DLL)  r)Nr<) r>r?r@rArYrrhrerjrBr)r!r[r[s=L##$$t4GY4  r)r[ceZdZUdZded<ded<ded<ded<ded<ded<d ed <d ed <d ed <d Zded<eeZded<ddZ y)BindingIntegrityuFproperly-bound 무결성 (live cron id == ledger id · role=fallback).r=r,completed_presentrole_is_fallback chat_ownedlive_eq_ledgermarker_eq_ledger Optional[str]ledger_fallback_cron_id live_cron_idmarker_fallback_cron_idFsingle_live_fallbackrbrdrecd|j|j|j|j|j|j |j |j|j|jt|jd S)Nz!task-2553+48.binding_integrity_v1) rgr,rmrnrorvrprqrsrtrure) r,rmrnrorvrprqrsrtrurhreris r!rjzBindingIntegrity.to_dictsq9''!%!7!7 $ 5 5//$($=$="11 $ 5 5'+'C'C --'+'C'CDLL)  r)Nr<) r>r?r@rArYrvrrhrerjrBr)r!rlrlsYP H****!&$&t4GY4 r)rlcFeZdZUdZded<ded<ded<dZded <d d Zy ) FallbackFireProofu7normal success 후 fallback 발화 0 end-to-end 입증.r= cron_removedintpost_success_fire_attemptsfallback_fired_countr:notecbd|j|j|j|jdS)Nz#task-2553+48.fallback_fire_proof_v1)rgrzr|r}rrzr|r}rris r!rjzFallbackFireProof.to_dicts1; --*.*I*I$($=$=II   r)Nr<)r>r?r@rArYrrjrBr)r!ryrys%A ##D#N r)ryceZdZUdZded<ded<ded<ded <ded <ded <ded <ded <ded<ded<ded<ded<ded<ded<eeZded<y)CancelOnSuccessE2EResultu<cancel-on-success live remove end-to-end 1회 실증 결과.r:verdictr=properly_boundr[binding_constructionrlbinding_integritydurable_success seam_invokedcron_remove_invokedfallback_cancelledfallback_preservednormal_success_unchangedryfallback_fire_proofr live_resultr e2e_auditrre2e_audit_pathrbrdnotesN)r>r?r@rArYrrhrrBr)r!rr sfF L55''""****O!!T2E92r)rr~ts_kstc Fg}t|j|j|j|jt |j |j|j|jdd| }|j||jdt||j|j|j|jt |j |j|j|jd| }|jd|jd|jd|j|j}td |j!|j|j|r|j!nd t |j"| S) udispatch 시 +44 guard 정합 기록 + +47 write-back COMPLETED 갱신. 절차 (회장 §3.1): 1. +44 ``make_record`` 로 REGISTERED 4-tuple(role=fallback, normal_collector_cron_id + fallback_callback_cron_id 정합) 을 append (durable guard 기록 — +44 append-only API only, byte-0). 2. +47 ``write_back_completed`` 로 normal durable-success COMPLETED line append (verified normal-collector identity 바인딩 — naive mark_completed 의 stale role/null copy 결함 회피). → ledger 최신 record = COMPLETED·role=fallback·fallback_callback_cron_id bound (live cron id == ledger id 일치 보장의 ledger 측 근거). REGISTEREDF) rQrRrSrTrUrVrWrXr. no_fallbackru|+44 guard: REGISTERED 4-tuple append (role=fallback, normal_collector+fallback 정합) — append-only API only (+44 byte-0)) rQrRrSrTrUrVrWrXrru+47 write_back_completed → z (appended=uf) — normal durable-success COMPLETED 갱신, naive mark_completed stale role/null copy 결함 회피TNr\r]r^r_r`rare)r rQrRrSrTr:rUrVrWrXrMr r.appended latest_forr[to_jsonra)registrytuprreguardwb completeds r!build_properly_bound_4tupler"sj&G  OO--CKK !$!=!="%"?"? XX E OOE NN R  OO--CKK !$!=!="%"?"? XX B NN ' {3[[M"B B ##CKK0I &"&]]_;;09**,t,,- r))expected_chat_id expected_rolec`g}|j|}t|duxr|jdk(}|s|jdt|duxr|jxsd|k(} | s|jd|dt|duxr!t |j t |k(} | s|jd| |jnd} |D cgc],} | jd|k(r| jd |k(r| .} } t| d k(}| r| d jd nd}|s|jd t| dt|xr | xr |xr|| k(}|s|r|jd|d| dt|tr|jdnd}t|tr|jdnd}t| xr |xr|| k(}|s|jd|d| d|xr| xr| xr |xr|xr|}t|||| | ||| |||xsdg Scc} w)u\properly-bound 무결성 검증 — live cron id == ledger id · role=fallback. 회장 §3.1 "live cron id == ledger id 일치 보장" 의 코드 검증: * ledger 최신 record = COMPLETED (+47 write-back 적용됨) * record.role == fallback, record.chat_id == ANU * record.fallback_callback_cron_id == live cron entry.id (live==ledger) * record.fallback_callback_cron_id == marker.callback_policy_a. fallback_callback_cron_id (==marker) 하나라도 불만족 → ``ok=False`` → +45 보수 가드 경로(보존·decouple). N COMPLETEDuFledger 최신 record 가 COMPLETED 아님 → +47 write-back 미적용r~zledger role != u → properly-bound 아님u$ledger chat_id 가 ANU 소유 아님rQrXr+rr$utask/role 매칭 live fallback u[건 — 정확히 1건이어야 properly-bound (모호 binding → 보존, Codex F1 수용)z live cron id(z) != ledger id(u&) → properly-bound 4-tuple 불성립callback_policy_arWzmarker fallback id(u) → 4-tuple 정합 실패u.properly-bound 4-tuple 무결성 전수 통과) r,rvrmrnrorprqrsrtrure) rr=r.rMrXr:rUrWr%len isinstancerrl)rrQrrlive_cron_entriesdispatch_markerrerecrmrnro ledger_fidr matchesrvlive_idrppol marker_fidrqr,s r!verify_4tuple_binding_integrityrks(G   g &CS_J{1JK  T CtOQRM0QR m..H I  4EC ,4D0EEJ =>25/..tJ# 55 w &155=M+I G w<1,&-gajnnT"4G -c'l^z>jJ&> !*0~8 :       !        1+)%) * *MLM  as1H+c|j}|r"|jr|jjnd}|y|jxsi}|j dS)Nchecks) wired_result wiring_result seam_outcomelive_verificationr%)rwrsolvs r!_five_conditionsrsQ  ! !B+-"2B2B   & &B z   #B 66( r)NF) rfallback_cancelled_marker_pathcancel_lock_pathseam_audit_pathcallback_contractrrr|skip_binding_constructionrc(tt|}|rT|j|j}t didd|r|j ndt |jdg}nt|||}t||j||| j| }t||||||||| j| | |||||}|jr6|jjr |jjjnd}|rt!|j"nd}|j$(t'(fd | jD}| jDcgc]_}|j)d |jk(r?|j)d |k(r+|j)d rt |j)d a}}(|vr|j+(d } t-t/d |D] }!|D]}"| j1|"s| dz } "t3||| |r| d k(rdnd}#t!|j4}$|s_|j6rS|j8j:t<k(r6|j>r*|j@r|r|r| d k(r|$r|jBrtD}%n'|j>r|j@r |stF}%ntH}%tK||||#|%|j6xr| (}&tM|&|| |jN}'tQ|%|j6xr| |||$|j>|j@||jR|jB|#||&|'gdScc}w)u"properly-bound 4-tuple 기반 cancel-on-success live remove end-to-end. 절차 (회장 §3): 1. +44 guard 정합 기록 + +47 write-back COMPLETED → properly-bound 4-tuple 구성 (``skip_binding_construction`` 시 외부 ledger 상태 그대로 — mismatch/missing 보수 가드 무회귀 재현용). 2. properly-bound 무결성 검증 (live cron id == ledger id·role= fallback). 불만족이어도 +45 가 보수적으로 보존하는지(무회귀) 그대로 진행 — 본 모듈이 cancel 을 강제하지 않는다. 3. +45 ``run_cancel_on_success_live_wiring`` **경유** (PRIMARY — 신규 cancel 로직 0). +37→+25→+23 seam 1회 → live verifier 5조건 AND → bound fallback 1건 cron-remove(주입 WorldSpyRemover, 실 운영 cron 무접촉). 4. normal success 후 fallback 발화 0 입증: 제거 후 격리 세계에서 fallback 발화를 ``post_success_fire_attempts`` 회 시도 → 전부 미발화(0) 여야 end-to-end 성립. 5. e2e cancel-audit JSON 생성·보장 기록. seam/cron-remove 의 어떤 예외·skip·실패도 normal collector success 를 뒤집지 않는다(디커플 — +45 권위 그대로, normal_success_unchanged=True 불변). FSKIPPED_EXTERNAL_LEDGERNuhbinding 구성 skip — 외부 ledger 상태 그대로 (mismatch/missing 보수 가드 무회귀 재현)rr)rQrrrr)dispatch_fired_marker_pathresult_json_path report_pathcollector_result_marker_path claim_dirra cron_listerremoverrrrrrrc3lK|]+}|jdk(xr|jd-yw)r$r2N)r%).0r targets r! z1run_cancel_on_success_live_e2e..Ms7  d v2!%% "22s14rQrXr$rr+unormal durable-success 후 bound fallback cron 이 실제 제거되어 이후 발화 시도 전부 미발화(0) — end-to-end 입증 (회장 §3)ufallback 미제거(보존) — properly-bound 불성립/5조건 미충족 보수 가드 경로. normal success 는 디커플로 무변(+45 무회귀)r)r construction integrity fire_proofrrtarget_cron_id)rrevent_id)uqproperly-bound 4-tuple = +44 guard 정합 기록 + +47 write_back_completed COMPLETED (live cron id == ledger id)u+45 run_cancel_on_success_live_wiring 경유 — 신규 cancel 로직 0, +37→+25→+23 seam·5조건 verifier 권위 그대로uLayer A: 실 운영 cron 무접촉(격리 FakeCronWorld/Spy) / Layer B: bound·verified single cancel 1건 (회장 §1 목표 자체)u디커플: normal_success_unchanged 절대불변 — cancel 실패/skip/exception 이 normal success 를 뒤집지 않음 (+45 권위 상속))rrrrrrrrrrrrrrr)*r rrrQr[rr:rarrrrr0rrrr=rrWanyr%rMrangemaxr6ryrr,lookupr.r rrrrrr_build_e2e_audit_write_e2e_auditrrr))inpack_pathrrrrrrrarrFrrrrrrrrr|rrrrrrrrrrzr fallback_idsr5_fidrrrr audit_writtenrs) @r!run_cancel_on_success_live_e2ers}Z&d;&78H!!!#++.2&+6$.1S[[]tH001:  3 c& 0 )#--' I4 #=)%ALL'E)'+)#!K,  $ $((66   ..;;  9;b334 * *FL 55 s{{ * EE&M] * EE$K AEE$KL\!F# E 3q45 6 C**3/  #!#="  Z^ J;667O & LL    % % 8  $ $  + +   QJ   0 0   + +"  ! ||E,E(EI%%%% M $ ||E,E(E)#' --';;-&99!,!E!E&$   OsA$McPt|jtr |jni}idtd|jxs|j j dd|j j d|xsdd|dt|d |j jd |jd |jd |d t|dt|jdt|jdt|jdddt|jd|jdt|jt|j |j j"|j j$ddg|jddS)ue2e cancel-audit 단일 레코드 (schema 정합). ``normal_success_unchanged`` 는 디커플 절대불변 — 무엇이 와도 True (회장 §3: cancel 실패/skip/exception 이 normal success 를 뒤집지 않음). rgrz|e2erQrz rr lookup_statusrr cancel_auditfive_condition_resultsrrrFrr&wired_via_operational_collector_wiringu<task-2553+48 cancel-on-success live remove END-TO-END 실증uproperly-bound 4-tuple(+44 guard + +47 write-back) → +45 wiring → +37→+25→+23 seam → 5조건 AND → bound fallback cron-remove → normal success 후 fallback 발화 0ts_utc)rcanonical_rootrarr)rrrE2E_AUDIT_SCHEMArrrQr=r.rjrrrr%rrrrra)rrrrrrrcas r!rrs&0  $& ! ! & "& K((O{/A/A/I/I.J$,O&  ;%%--&  .7K &  7 &  $~. &  ++22&   4 4 6&  Y..0&  &  !"2;"?&  [556&  tK$C$CD&  d FF' / & " d;#A#AB#& $ z113%& & 1$  > >3 '& 4%)  0 0% &,,;;"))55 J C &&"K& &r)c | t|nt|tdz }djd|xsdDdd}t||t|td|dz gS) uQe2e cancel-audit 다중 후보 보장 기록 (Layer A — NO-CRON, 디커플 IO).Nz.cancel-audit.jsonr~c3DK|]}|jr|ndyw)rN)isalnum)rcs r!rz#_write_e2e_audit..sKQAIIKqS0Ks Pz.cancel-audit.z.json)primary fallbacks)rTASK_MARKER_PREFIXjoinr)auditrrrrsafe_eids r!rrs  % ^ )_"4!55GH H wwK8>rKKCRPH !  O#$N8*EB C  r))rrrrrrrDrPr[rlryrrrr)rr rrPrr:r8r[)rr rQr:rUnion[int, str]rr:rr7rrr8rl)rrr8r;).rrrUnion[str, Path]rrPrrrrrrrrrrrarrrrFrrrDrOptional[Union[str, Path]]rrrrrrrr;rrrr:r|r{rr=rr:r8r)rrrr[rrlrryrr:rr=rr:r8r) rrrrrrrr:r8rr)1rA __future__r dataclassesrrpathlibrtypingrrr anu_v3.callback_4tuple_registryr r anu_v3.callback_event_triggerr $anu_v3.cancel_on_success_live_wiringr rranu_v3.cancel_audit_writerrutils.live_cron_state_verifierrr(utils.anu_delegation_completion_callbackrrrrrrrrrDrPr[rlryrrrrrrr__all__rrBr)r!rs;&N#(((     $@   22j  <          0     @     $ 33 30 F$F F  F ! FZ)4& i$ii& i  i " iiiX.26AE3726(,(3&&'&+/V VV V !1 V ' V"V#3V V"VV VV/V%?V 1!V"0#V$&%V&&'V()V*!$+V, $-V. /V01Vr8*8.8 8 " 8  888 8v  /     0 &r)