0bj]dZddlmZddlZddlZddlZddlmZmZm Z ddl m Z ddl m Z mZmZmZmZdZdZd Zd Zd Zd Zd ZeeeefZGddeZGddeZd$dZedGddZed d%dZGdde Z!dZ"de"zZ#d&dZ$e e%e%ge&fZ'GddZ(d'd(d Z)d)d!Z*d'd*d"Z+e,d#k(r e-e+y)+uanu_v3.dispatch_callback_contract — dispatch callback/progress-trigger 계약 (task-2614 §7b · 회장 2026-05-20 야간 필수 보강). 회장 verbatim mandate (BATCH_LEVEL_HOLD 시스템 필수 보강 — 새 범위 아님): 모든 executor dispatch 는 (1) normal completion callback(독립 ANU key) 와 (2) ANU-key fallback safety-net(미수신 recovery 전용·NON_BLOCKING) 둘 다 등록하는 계약을 가져야 한다. normal callback durable-success 즉시 fallback 은 cancel-on-success 로 제거된다(노이즈 0). fallback 은 *recovery 전용* — 진행 트리거가 아니다(fixed-time/dead-man 진행트리거 금지). normal·fallback 둘 다 부재면 ``DISPATCH_CONTRACT_VIOLATION`` 이다. ``result exists + normal missing + fallback missing`` 조건(=DISPATCH_CONTRACT_VIOLATION)에서만 recovery watcher 가 **idempotent** 하게 독립 ANU collector 를 1회 spawn 한다 (중복 0). 무조율 dead-man/fixed-time 진행트리거는 절대 금지 — 640665C8 안티패턴(무조율 fixed-time ANU-key cron 진행트리거) 재발 차단. executor self-key 는 collector/adjudication/dispatch 에 절대 사용 불가(독립 ANU key 전용 · +49 정본). 데몬 안전원칙 (§7b.7): sense / act / think 분리 · dry-run 우선 · 관측 후 행동. recovery watcher 는 상태를 변경하지 않고 조건만 탐지(sense)하고, 조건 충족 시 정확히 1회 spawn(act)하며, self-record 로 재진입을 차단한다. Layer A / NO-CRON / NO-WRITE: 본 모듈은 ZERO cron register/remove, ZERO subprocess, ZERO cokacdir, ZERO network, ZERO 파일쓰기(엔트리포인트 CLI 의 ``--output`` 명시 경로 제외)다. spawn 은 *주입된* collback(``spawn_fn``)으로 위임 — 본 모듈은 실제 dispatch/cron/credential 표면을 import 하지 않는다. 기존 ``anu_v3.executor_callback_contract``(+32 doctrine) 는 무수정 — 본 모듈은 그 doctrine 을 dispatch 계약 *런타임 분류기*로 확장(중복 구현 0). ) annotationsN)asdict dataclassfield)Path)CallableDictListOptionalSequencez$anu_v3.dispatch_callback_contract.v1c119085addb0f8b71e41a2324a3ccdd0 CONTRACT_OKDISPATCH_CONTRACT_VIOLATIONRECOVERY_SPAWNEDFALLBACK_RECOVERYceZdZdZy)ContractViolationu0dispatch callback 계약 위반 — fail-closed.N__name__ __module__ __qualname____doc__R/home/jay/workspace/.worktrees/task-2696-dev7/anu_v3/dispatch_callback_contract.pyrr>s:rrceZdZdZy)ExecutorSelfKeyForbiddenuexecutor self-key 를 collector/adjudication/dispatch 에 사용 시도. 독립 ANU key(c119085addb0f8b7) 전용 — executor self-key (1e41a2324a3ccdd0) 는 절대 금지(+49 정본). fail-closed. NrrrrrrBrrcr|tk(rtd|d|tk7rtd|dtdy)ucollector/adjudication/dispatch key 가 독립 ANU key 인지 강제. executor self-key 또는 그 외 임의 key 면 ``ExecutorSelfKeyForbidden`` (fail-closed). 약화 우회 불가. zexecutor self-key uc 는 collector/adjudication/dispatch 에 절대 사용 불가 — 독립 ANU key 전용(+49 정본)zcollector key u 는 독립 ANU key(u6) 가 아님 — fail-closed(self-chain 약화 금지)N)EXECUTOR_SELF_KEY_FORBIDDENrINDEPENDENT_ANU_KEY)keys r'assert_collector_key_is_independent_anur$Jse  ))& (I I   !!&SG#78K7LM? ?  "rT)frozenceZdZUdZded<ded<ded<ded<ded<ded <ded <ded <ded <ded <ded<ded<eeZded<ddZdddZ y)DispatchContractRecordu5dispatch_callback_contract.v1 레코드 (schema 1:1).strschematask_idboolnormal_callback_presentfallback_presentresult_presentclassificationidempotency_key collector_keyexecutor_self_key_forbiddenfallback_cancel_on_successrecovery_required"recovery_is_fixed_time_or_dead_man)default_factory List[str]reasonsct|SN)rselfs rto_dictzDispatchContractRecord.to_dictns d|rcNtj|jd|S)NF ensure_asciiindent)jsondumpsr=)r<rAs rto_jsonzDispatchContractRecord.to_jsonqszz$,,.uVLLrN)returndict))rAintrEr() rrrr__annotations__rlistr8r=rDrrrr'r'\se? K L!!!%% $$(,,t4GY4Mrr')r1ct|t|}t|}t|}g}d|}|r,t}t|}d} |jd|rdndzng|rt}d}d} |jdnIt }d}t|} |jd|r|jdn|jd t t|t|t|t||||d || d| S) u단일 dispatch 의 callback 계약 분류 (공개 entrypoint · 순수 함수). §7b 런타임 계약 1~6 을 코드로 강제한다: * normal callback 수신 → ``CONTRACT_OK``. fallback 은 cancel-on-success(노이즈 0). (계약 1·3) * normal 미수신 · fallback 존재 → ``FALLBACK_RECOVERY`` — 미수신 recovery 안전망(진행트리거 아님·NON_BLOCKING). (계약 2·4) * normal·fallback 둘 다 부재 → ``DISPATCH_CONTRACT_VIOLATION``. result 까지 존재(=계약 6 조건)면 recovery watcher 가 독립 ANU collector 를 1회 spawn 해야 한다(``recovery_required=True``). result 부재면 위반이되 spawn 조건 미충족(no-op·진행트리거화 0). (계약 5·6) collector_key 는 독립 ANU key 만 허용 — executor self-key 면 fail-closed. recovery 는 *조건 탐지* 결과일 뿐 fixed-time/dead-man 진행트리거가 아니다(``recovery_is_fixed_time_or_dead_man`` 는 항상 False — 640665C8 안티패턴 재발 차단의 코드 명문). task-2620 §2.2 H1 hardening: CONTRACT_OK edge case 입력 정규화. mixed-signal (예: normal_callback_present=True 인데 fallback_present 가 None/non-bool) 도 ``bool(...)`` 으로 강제하여 truthy 잡음을 차단한다. truthy 비-bool 입력은 boolean 정규화 후 그대로 평가 — 약화 없음. zdispatch_callback_contract:Fu>normal completion callback 수신 → CONTRACT_OK (계약 1). uPfallback durable-success 즉시 cancel-on-success 제거(노이즈 0·계약 3).u;fallback 미등록이나 normal 수신으로 계약 충족.unormal callback 미수신 · fallback safety-net 존재 → FALLBACK_RECOVERY (계약 2·4). fallback 은 미수신 recovery 전용·NON_BLOCKING — 진행 트리거 아님(fixed-time/dead-man 금지).uanormal callback · fallback safety-net 둘 다 부재 → DISPATCH_CONTRACT_VIOLATION (계약 5).uresult 존재 + normal 미수신 + fallback 미수신 — recovery watcher 가 독립 ANU collector 를 idempotent 1회 spawn 해야 함 (계약 6). 무조율 dead-man/fixed-time 진행트리거 금지 (640665C8 안티패턴 차단).u~result 부재 — 계약 6 spawn 조건 미충족. recovery watcher no-op(진행트리거화 0 · fixed-time/dead-man 아님).T) r)r*r,r-r.r/r0r1r2r3r4r5r8)r$r+rappendrrr'CONTRACT_SCHEMA) r*r,r-r.r1r8r0r/r3r4s rclassify_dispatch_contractrNusD@,M: ##:;,-.)NG3G9=O$%)*:%;"! L$ S    *%*"! \ 5%*"!0 6   NN2  NNM  " $%< =./N+%'#$(#=++0 rceZdZdZy)InvalidObservationutask-2620 §2.2 H2 — evaluate input coercion fail-closed. 빈 dict · None · wrong type · required-key 누락 입력을 받았을 때 silent normalization 대신 즉시 명시 예외를 발생시킨다. 약화 우회 0. NrrrrrPrPrrrP)r,r-r.)r*c | tdt|ts"tdt|jd|stdt dt Dcgc] }||vs| }}|rtd|dt D]X}||}|td|d t|tttfr5td|d t|jd t|jd d }t|jdt}t|t|jddt|jddt|jdd|Scc}w)u@실 entrypoint: observation dict(또는 fixture) → 계약 레코드. mock-only 경로는 본 함수를 우회할 수 없다 — 실제 관측값을 분류한다. task-2620 §2.2 H2 hardening: input-coercion fail-closed. * ``observation is None`` / dict 아님 / 빈 dict → InvalidObservation. * required key (task_id + 3 boolean signal) 부재 → InvalidObservation. * boolean signal 이 None / non-bool non-truthy-coerce 가능 type → 즉시 InvalidObservation 으로 차단 (실수로 dict / list 가 들어오면 정상 bool(...) 이 항상 True 가 되어 분류가 왜곡되는 경로 봉합). 기존 PASS-path (정합 fixture · dict 입력) 는 byte-0 — 어느 fixture 도 실패하지 않는다(H2 regression 케이스 + 기존 cases (a)~(f) 둘 다 PASS). uWobservation is None — dispatch contract 평가에는 dict 가 필요 (H2 fail-closed)zobservation must be dict, got u — wrong type fail-closed (H2)u5observation is empty dict — required keys missing (u) — H2 fail-closedz%observation missing required key(s): u — H2 fail-closedz observation[u6] is None — boolean signal required (H2 fail-closed)z] type u4 is not bool/int/str — wrong type fail-closed (H2)r*z task-unknownr1r,Fr-r.r*r,r-r.r1) rP isinstancerFtyper_OBSERVATION_REQUIRED_KEYS_OBSERVATION_BOOL_KEYSr+rHr(getr"rN) observationkmissingvr*r1s revaluater\s      k4 ( ,T+->-G-G,HI* *     *++? A  5MQ8LqMGM 3G9!+%)%5T 35 rct|S)u@관측만 — 상태 변경 0. 분류 레코드를 반환한다.)r\)r<rXs robservezRecoveryWatcher.observeTs $$rc|jtk(xr8|jxr*|j xr|j xr |j S)u계약 6 조건: result 존재 ∧ normal 미수신 ∧ fallback 미수신 (= DISPATCH_CONTRACT_VIOLATION ∧ recovery_required).)r/rr.r,r-r4)r<recs r_spawn_condition_metz$RecoveryWatcher._spawn_condition_metZsZ   "= = &"" &/// &((( &%%  rc|j|}d|j|jd|jdd}|j |sd|d<|S|j|j vr d|d<d|d<|S|j j |j |j|j|j}|jd|d |S#t$r'|j j|jwxYw) u조건 충족 시에만 독립 ANU collector 를 1회 spawn (idempotent). 반환: {spawned, classification, idempotency_key, duplicate_suppressed, reason}. 조건 미충족이면 spawned=False(no-op·진행트리거화 0). F)spawnedr/r0duplicate_suppressedr1fixed_time_or_dead_manu|spawn 조건 미충족(result+normal-missing+fallback-missing 아님) — no-op. fixed-time/dead-man 진행트리거 아님.reasonTrnuGidempotency_key 이미 spawn 됨 — 중복 spawn 0 (재진입 차단).uDISPATCH_CONTRACT_VIOLATION(result+normal-missing+fallback-missing) — 독립 ANU collector 1회 spawn. 무조율 dead-man/fixed-time 진행트리거 아님(640665C8 차단). atomic mark-then-act (H3) — 동시/재시도 경계 중복 0.)rm spawn_resultrp) rhr/r0rbrkrdaddrar* BaseExceptiondiscardupdate)r<rXrjoutrqs r maybe_spawnzRecoveryWatcher.maybe_spawnfs ll;'!00"22$)!00&+ " ((-Q MJ   $-- /*.C& 'Y MJ #--. >>#++t7J7JKL %R     MM ! !#"5"5 6   s &C0Dc,t|jSr:)sortedrdr;s r spawned_keyszRecoveryWatcher.spawned_keyssdmm$$r)reSpawnFnr1r(r_z Optional[set]rENonerXDict[str, object]rEr')rjr'rEr+)rXr~rEr~)rEr7) rrrrr"rfrhrkrwpropertyrzrrrr^r^5s(1" A A A  A  A%,% %  <,< <|%%rr^c g}tdddd}|jtk7s |js+|j d|jd|jtdddd}|jt k7s |j r+|j d|jd |j |xsd }t|}|js,ttjjd d |z } tj|jd }t'|jd|}|jt(k7s |j s+|j d|jd |j gt+fd} | j-|jd|} | j-|jd|} | dr| dst/dk(s#|j dt/d| d| gt+fd} | j-ddddd} | dsr|j d| d} tddddt0 |s|j d!|j|jk7}d| |t%||gd"d#S#t$r3}dddt!|j"d|t%|dcYd}~Sd}~wwxYw#t2$rd}YwxYw)$uM실 entrypoint regression. 회장 필수 fixture(callback-gap)를 read-only consume 하여 DISPATCH_CONTRACT_VIOLATION + recovery 경로를 실증한다. mock-only 경로는 본질적으로 실패한다 — 상수 분류기는 (a)CONTRACT_OK 와 (c)DISPATCH_CONTRACT_VIOLATION 을 동시에 만족시킬 수 없다. ztask-selftest-aT)r*r,r-r.z(a) z fc=ztask-selftest-bFz(b) z rr=z0memory/fixtures/task-2614.case-callback-gap.jsonWORKSPACE_ROOTz/home/jay/workspaceutf-8encodingz/anu_v3.dispatch_callback_contract.self_check.v1zfixture read fail: z: )r) all_passederrorfixtureNrXz(c) c.j|xsdS)NrmrL)tid_keycallss rz run_self_check..s%,,s*;*Hyrrmz (d) spawns=z r1=z r2=c&j|Sr:r)rrcalls_es rrz run_self_check..sGNN3,?rztask-selftest-ez(e) unexpected spawn noop=ztask-selftest-frRz%(f) executor self-key NOT fail-closed)abcdef)r)rfailuresrmock_only_would_failcases)rNr/rr3rLrr4r is_absoluteosenvironrWrBloads read_text ExceptionrTrr(r\rr^rwlenr!r) fixture_pathrrrfxfxpobsexcrwr1r2w_enoopself_key_fail_closedrrrs @@rrun_self_checkrsH #! $  A  ;&a.J.J$q//0Q5Q5Q4RST #! %  A  ,,0C0C$q//0Q5H5H4IJK  : r(C ?? 2::>>"24IJKbP jj89 ,-A66a>Q>Q1##$D)<)<(= > EHIA sww}c2 3B sww}c2 3B yM"Y-CJ!O+c%j\bTbTBCG ? @C ??('+ %"   D I'4TF;<! $"%$(!5   ?@++q/?/??D"ls8 4/  k  G*49+=+=*>bF3x    Z $$#$s0%J5 K45 K1>(K,&K1,K14 LLctjdd}|jddd|jddd |jd dd |S) Ndispatch_callback_contractu{task-2614 §7b — dispatch callback/progress-trigger 계약 런타임 (회장 야간 필수 보강 · 문서-only 금지).)prog descriptionz --selftest store_trueu 실 entrypoint regression 실행)actionhelpz --fixtureu;callback-gap fixture 경로 (기본: 회장 필수 fixture))defaultrz --evaluateu0observation JSON 경로 → 계약 분류 출력)argparseArgumentParser add_argument)ps r _build_parserrsl )I A NN< :<NN;UWNN<JL Hrctj|}|jrmtjt |jj d}t|jd|}t|jyt|j}ttj|dd|jdrdSd S) NrrrXrFrGr?rr) r parse_argsr\rBrrrrWprintrDrrrC)argvargsrrjress r_mainrs ? % %d +D }}jjdmm,666HIsww}c23 ckkm  &C $**SuQ 78 %1,1,r__main__)r#r(rEr|) r*r(r,r+r-r+r.r+r1r(rEr'r}r:)rz Optional[str]rEr~)rEzargparse.ArgumentParser)rzOptional[Sequence[str]]rErH).r __future__rrrBr dataclassesrrrpathlibrtypingrr r r r rMr"r!rrrrCLASSIFICATIONS RuntimeErrorrrr$r'rN ValueErrorrPrVrUr\r(objectr{r^rrrr SystemExitrrrrsi:# 00;;8)0 ;%' ; ;| $ $MMM<- g g"g g  g  ggT *,BB?F C:v% &q%q%jbJ   - z UW r