3jjdZddlmZddlZddlZddlZddlmZmZm Z ddl m Z ddl m Z mZmZmZddlZdZdZd Zd Zd Zd Zd ZdZeeeeeeefZdZdZdZeZdZe eehZ!edGddZ"eGddZ#eGddZ$d$dZ%ef d%dZ&ef d&dZ'd'dZ(d(dZ)d)d Z*d*d+d!Z+gd"Z,e-d#k(r e.e+y),u anu_v3.batch_hold_adjudicator — batch-level consolidated HOLD adjudicator (회장 BATCH_LEVEL_HOLD_ADJUDICATION 시스템화 Track A · task-2610). 회장 verbatim 목표: 병렬 작업 중 Codex HIGH/HOLD 가 발생해도 개별 track 만 보고 회장에게 멈추지 말고, batch 전체 context 를 모은 뒤 Critical7 인지 non-critical remediation 인지 자동 분류하고, Critical7 이 아니면 ANU-Codex loop 로 자동 remediation 하여 all-settled 까지 진행한다. 본 모듈의 단일 책임 (Track A): * 모든 track 의 상태(collector 기록·independent-ANU verdict·Track B Critical7 분류·dependency·dispatch)를 **하나로 모아** consolidated adjudication 을 수행한다. * 분류 taxonomy (회장 verbatim 7종): AUTHORITATIVE_PASS · HOLD_CANDIDATE · AUTO_REMEDIATION_HOLD · CHAIR_HOLD · WAITING_FOR_DEPENDENCY · NOT_STARTED_BY_DESIGN · DISPATCH_NOT_RECEIVED * **개별 collector 는 HOLD_CANDIDATE 만 기록**한다. collector 가 최종 분류(AUTHORITATIVE_PASS/CHAIR_HOLD 등)를 자칭하면 그 자칭은 *무시* 되고 본 batch-level adjudicator 가 재도출한다 (collector self-finalization 금지 — §3/§5). * **최종 분류는 본 batch-level adjudicator 만** 권위가 있다. * Track B classifier 결과(Critical7 여부)를 입력으로 받아 **CHAIR_HOLD vs AUTO_REMEDIATION_HOLD** 를 확정한다. classifier 결과가 없으면 HOLD_CANDIDATE 로 fail-closed (자동 PASS·자동 수렴 금지). * shared invariant 파손 또는 Critical7 = 전체 CHAIR_HOLD (회장 보고). 그 외 non-Critical HOLD 는 AUTO_REMEDIATION_HOLD 로 자동 수렴 — 회장 보고 0. * independent-ANU verdict 만 authoritative. self-chain PASS 자칭만으로 AUTHORITATIVE_PASS 부여 금지(§5.D fail-closed → HOLD_CANDIDATE). Layer A / NO-CRON: 순수 분류 함수. ZERO cron / dispatch / subprocess / cokacdir / network / 파일 쓰기(엔트리포인트 CLI 의 --output 명시 경로 제외). 회수·발사·등록·remediation 실행 0 — *판정만* 한다. callback owner=독립 ANU key (executor self key 금지·+49 정본) 는 본 모듈이 강제하지 않고 ``anu_v3.callback_owner_validator`` 가 등록 직전 강제한다(중복 구현 금지). ) annotationsN)asdict dataclassfield)Path)DictListOptionalSequencez!anu_v3.batch_hold_adjudication.v1AUTHORITATIVE_PASSHOLD_CANDIDATEAUTO_REMEDIATION_HOLD CHAIR_HOLDWAITING_FOR_DEPENDENCYNOT_STARTED_BY_DESIGNDISPATCH_NOT_RECEIVEDPASSFAILHOLD_FOR_CHAIR)c119085addb0f8b7T)frozenceZdZUdZded<ded<dZded<dZded <dZded <dZded <dZ ded <d Z ded<dZ ded<dZ ded<dZ ded<dZded<d Zded<dZded<dZded<dZded<dZded<dZded<y )TrackHoldInputuXOne track's consolidated raw state fed to the adjudicator. Every signal is *evidence*, never a final verdict — the adjudicator re-derives the classification. ``collector_recorded`` carries only what an individual collector is permitted to emit (HOLD_CANDIDATE); any other self-finalization claim is recorded and ignored. strtrack_idtask_idTbooldispatch_receivedFnot_started_by_designdependency_unmetshared_invariant_breachhold_candidateNz Optional[str]collector_recorded collector_key executor_keycollector_role"collector_session_is_executor_selfauthoritative_verdict authoritative_is_independent_anuclassifier_presentclassifier_is_critical7classifier_categorydetail)__name__ __module__ __qualname____doc____annotations__rrr r!r"r#r%r&r'r(r)r*r+r,r-r.4/home/jay/workspace/anu_v3/batch_hold_adjudicator.pyrrZsM L"t""'4'"d"$)T) ND (, ,M3L#NC/4&4,0=/-2$d2 %$$)T)!!FCr5rcfeZdZUded<ded<ded<ded<ded<ded<ee Zd ed <y ) TrackAdjudicationrrrclassificationrchair_escalationauto_remediationsettleddefault_factory List[str]reasonsN)r/r0r1r3rlistr@r4r5r6r8r8}s2M L Mt4GY4r5r8ceZdZUded<ded<ded<ded<ded<ded<ded <ded <d ed <d ed<ded<eeZded<ddZdddZy)BatchHoldAdjudicationrschemaverdictbatch_classificationr all_settledchair_escalation_requiredauto_remediation_requiredcritical7_presentr!int track_countzDict[str, int]classification_countszList[TrackAdjudication]tracksr=r?r@ct|}|SN)r)selfds r6to_dictzBatchHoldAdjudication.to_dicts 4Lr5cNtj|jd|S)NF) ensure_asciiindent)jsondumpsrS)rQrVs r6to_jsonzBatchHoldAdjudication.to_jsonszz$,,.uVLLr5N)returndict))rVrKrZr) r/r0r1r3rrAr@rSrYr4r5r6rCrCs\ K L####!!)) ##t4GY4Mr5rCcl|Dchc]}|s| }}t|jxrI|j|vxr9|j|jk7xr|jdk(xr |j }|js|js |jrt|j xr|Sycc}w)uRe-derive independence from owner identity — claim is never trusted. Independent iff: track flags it independent AND collector_key is a configured ANU key AND collector_key != executor_key AND role==ANU AND the session is NOT the executor self-session (§5.D / +49 정본). A bare ``authoritative_is_independent_anu=True`` claim without a provable owner identity is downgraded to self-chain (fail-closed). ANUF)rr%r&r'r(r*)tanu_keyskkeyset owner_provens r6_independent_anurds" 'AQa 'F ' Q__ 5 OOv % 5 OOq~~ - 5    % 544 4  !..A,<,<A667HLH (s B1B1c g}|j2|jtk7r|jd|jd|jr;|jdt |j |j tddd|S|js;|jdt |j |j tddd|S|jr;|jdt |j |j tddd|S|jr;|jd t |j |j tddd|St||}|jxsd j!}|j"xs|jtk(xs|xr|d v}|r|j$s;|jd t |j |j t&ddd|S|j(rM|jd |j*xsddt |j |j tddd|S|jd|j*xsddt |j |j t,ddd|S|dk(rx|r;|jdt |j |j t.ddd|S|jdt |j |j t&ddd|S|jdt |j |j t&ddd|S)aRe-derive the authoritative classification for a single track. Precedence is fail-closed: a track only reaches AUTHORITATIVE_PASS via a provable independent-ANU PASS; everything ambiguous degrades to HOLD_CANDIDATE rather than silently passing. zcollector self-finalization u IGNORED — individual collector may record only HOLD_CANDIDATE; final classification is re-derived by the batch-level adjudicator (회장 §3/§5).uishared invariant breach detected -> CHAIR_HOLD (회장 §6: shared invariant 파손 = 전체 CHAIR_HOLD).TF)r:r;r<r@uqdispatch not received — track has no executor session; DISPATCH_NOT_RECEIVED (NOT a HOLD, NOT chair-escalated).utrack is NOT_STARTED_BY_DESIGN (event-gated / by-design idle) — terminal-good, counts toward all-settled, no chair, no remediation.udependency unmet — predecessor durable-success EVENT absent; WAITING_FOR_DEPENDENCY (event-driven, NOT fixed-time, NOT chair-escalated).r$)rHOLDruHOLD detected but Track B critical7/codex-high classifier result ABSENT — cannot finalize CHAIR vs AUTO; remains HOLD_CANDIDATE (fail-closed: NO auto-pass, NO auto-converge without classifier).z(Track B classifier: Critical7 (category= unspecifieduK) -> CHAIR_HOLD (회장 §6: Critical7 = 전체 CHAIR_HOLD, 회장 보고).z+Track B classifier: non-Critical (category=u^) -> AUTO_REMEDIATION_HOLD — ANU-Codex loop 자동 수렴 (회장 §3/§6: 회장 보고 0).ruhindependent-ANU authoritative verdict = PASS -> AUTHORITATIVE_PASS (회장 §5.D: independent ANU only).uPASS claimed by self-chain (no provable independent-ANU ownership) — confirming PASS from a self-chain verdict alone is FORBIDDEN (§5.D); degrades to HOLD_CANDIDATE (fail-closed).uno provable independent-ANU PASS and no resolved HOLD signal — fail-closed default HOLD_CANDIDATE (final classification deferred to a later batch-level adjudication once evidence arrives).)r#COLLECTOR_SIGNAL_HOLD_CANDIDATEappendr!r8rrrrrrrr rrdr)upperr"r+r r,r-rr )r_r`r@ independentav hold_paths r6adjudicate_trackrnsyG ( $C C*1+?+?*BC       < ! JJ :!E7     G ! JJ #8"U7     ! JJ #8"U'     ! JJ #9"U7  #1h/K ! ! 'R . . 0B  F  #B B F  DB"DD ## NN'  % AII~!&w  $ $ NN:((9M<=NN  % AIIz!%w  9$$5 89   ! JJ #8"T7   V|  NNK % AII'9!&g   K ! JJ >"U7   NN F  AII~w r5cJ|Dcgc]}t||}}tDcic]}|d}}|D].}|j|jddz||j<0t d|Dt fd|Dxst d|D}t d|D}t d|D} t |xrt d|D} g} |s|sr3t} t} r| jd |ro| jd n]| rt} t} | jd n=| rt} t} | jd nt} t} | jd tt | | | || |t#||||  Scc}wcc}w)u1Consolidated batch adjudication over ALL track states. 회장 §6: shared invariant 파손 또는 Critical7 = 전체 CHAIR_HOLD. 그 외 non-Critical HOLD 는 AUTO_REMEDIATION_HOLD 자동 수렴(회장 보고 0). all-settled = 모든 track 이 AUTHORITATIVE_PASS / NOT_STARTED_BY_DESIGN. rc34K|]}|jywrP)r!.0r_s r6 z#adjudicate_batch..gs&'!!c3NK|]}|jtk(xr ywrP)r9r)rsta shared_breachs r6rtz#adjudicate_batch..js/  Z'= ,==s"%c3PK|]}|jxr |j ywrP)r+r,rrs r6rtz#adjudicate_batch..ms$ PAQ ! ! ?a&?&? ? Ps$&c34K|]}|jywrP)r:rsrws r6rtz#adjudicate_batch..nsA,,Aruc34K|]}|jywrP)r;r{s r6rtz#adjudicate_batch..os@++@ruc3@K|]}|jtvywrP)r9 _SETTLED_GOODr{s r6rtz#adjudicate_batch..ps */1]**su]shared invariant 파손 track 존재 -> 전체 CHAIR_HOLD (회장 §6). 회장 보고 필요.uwCritical7 track 존재 -> 전체 CHAIR_HOLD (회장 §6). 회장 보고 필요. 그 외 non-Critical 은 자동 수렴.u^모든 track AUTHORITATIVE_PASS / NOT_STARTED_BY_DESIGN — batch all-settled. chair 보고 0.unon-Critical HOLD 존재 -> AUTO_REMEDIATION_HOLD 자동 수렴 (ANU-Codex loop). Critical7 0 · 회장 보고 0 · 진행 트리거는 event-driven (fallback/dead-man/fixed-time 아님).u미해결 HOLD_CANDIDATE / WAITING_FOR_DEPENDENCY / DISPATCH_NOT_RECEIVED 존재 — batch 미정착이나 chair-escalation 불요(Critical7·invariant 파손 0). 추가 evidence(EVENT) 도착 시 재-adjudication.) rDrErFrGrHrIrJr!rLrMrNr@)rnCLASSIFICATIONSgetr9anyrallrrrirr rrr rCADJUDICATION_SCHEMAlen)rNr`r_ per_trackccountsrw critical7chair_required auto_requiredrGr@rErFrxs @r6adjudicate_batchrWs9??1!!X.?I?,;*'KGm )  NN6   NNP  1 1  4 B -   !"1"0"/# - N$  w@<d?|d@< t%j&|| jdA r- D]'} t.j0j3dB| zdCz)yDt.j0j3dEyF#t$j($r(} jd;|j*Yd<}~d<}~wwxYw#t$j($rYwxYw)HuDrive the REAL entrypoint over real cases (no mocks). Non-zero exit on any mismatch — this is the regression backstop callable in-allowlist (Track E owns tests/regression/test_batch_hold_adjudication.py).c Zt|}|j|k7s|j|k7r3j|d|jd|jd|d| |j D];\}}t |||k7sj|d|dt ||d|=y)Nz: got verdict=/z want z: =)rrErFrirgetattr) namer want_verdict want_classwantrrarfailuress r6expectz_selfcheck..expects #G , 99 $(>(>*(L OO&qyyk13I3I2JK$~Qzl4 JJL MDAqq!}!4&1#Qwq!}.?vaU KL Mr5rc38fb9955616e24dall_passAz task-2610rTr^)rrr)r*r%r&r')r`rNF)rGrHnon_critical_autoBz task-2611test_harness_invariant)rrr"r+r,r-)rIrHrJcritical7_chairCz task-2612 credential)rHrJinvariant_chairDz task-2613)rrr!)rHr!hold_no_classifier)rrr"r+)rHrIself_chain_pass_quarantined)rrr)r*r%r&r'r()rHdep_and_designEz task-2614)rrr Fz task-2615)rrrGz task-2999)rrr)rHrGr )rrr#z@collector_self_final: claimed AUTHORITATIVE_PASS not ignored -> critical7_flag_no_pertrack_chairX)rrr+r,#bare_independence_claim_fail_closed)rrr)r*schemasz#batch_hold_adjudication.schema.jsonutf-8encodingz;schema_valid_c7: real critical7 output rejected by schema: NrrErrFzschema_reject_invariant_violation: invariant-violating output (critical7_present=true, verdict=FAIL) was NOT rejected by schemazSELFCHECK FAIL:  rpz)SELFCHECK PASS: 11 real-entrypoint cases r) rrrr[rrrrrZNone)rr rrrrr rrFrir__file__resolveparentrWloads read_textrS jsonschemavalidateValidationErrormessager[sysstderrwrite) ranu exec_selfr8 _schema_path_schema _valid_c7e_badfrs @r6 _selfcheckrs4H M M+/ M  C"I &,150)$  &%    d"'  #4(-$< >%  #"&%  #4(,$0 2&,150)$  & %   "&$$ (, .%    "& #5 B%   n"'5 %&,15'$37  9%   n  !% '&* ,"' ) %   n"'U  !c[3 5>" B .0 ))* ,  *#'D J%    "'4 -&,15 7%  n"'U >))+22999:Ljj///ABG'S[t$( , .E)    Iw/  ?DDO#:D   D'* P  @ TA{{| 77 12jjagg00'0BCG $W -F .. Cxx FQXXsTz4@  t$ r5)rr r rrrrrrrrrrrr8rCrnrr__main__)r_rr` Sequence[str]rZr)r_rr`rrZr8)rNzSequence[TrackHoldInput]r`rrZrC)rRr[rZr)rr[rZrC)rZrKrP)rzOptional[Sequence[str]]rZrK)/r2 __future__rrrWr dataclassesrrrpathlibrtypingrr r r rrr r rrrrrrrrrrhr frozensetr~rr8rCrdrnrrrrr__all__r/ SystemExitr4r5r6rs(R# 00119*!/  1// !#1)-/DEF  $D 55 5 MM M,6/\\\\B/R $RRRlJ . D : . z UW r5