jdZddlmZddlZddlZddlmZddlmZm Z m Z dZ dZ dZ ehd ZGd d eZdd Zddd  ddZ ddZy)uanu_v3.runtime_batch_state_updater — versioned/additive batch_state PROPOSAL. task-2553+31 ANU_RUNTIME_RECONCILE_CHECKPOINT leaf module (구현목표 14·15). 9-R.1 HARD BOUNDARY: "batch_state 자동 갱신" == a single NEW versioned/additive batch_state PROPOSAL artifact only: memory/events/task-2553.runtime-reconcile-checkpoint.batch-state.json The frozen durable v1 (memory/events/task-2553.parallel-batch-state.json) and ANY pre-existing batch-state-class file are read-only inputs: write/overwrite is ABSOLUTELY ZERO. The decision/derivation surface (build_proposal) is pure and writes nothing. Emission (emit_runtime_batch_state) is a SEPARATE, hard-guarded I/O function outside the decision boundary that refuses every forbidden path. ) annotationsN)Path)DictListOptionalz2anu_v3.runtime_reconcile_checkpoint.batch_state.v1z4batch-task-2553-runtime-reconcile-checkpoint-2553p31zEmemory/events/task-2553.runtime-reconcile-checkpoint.batch-state.json>0memory/events/task-2553.generic-batch-state.json1memory/events/task-2553.parallel-batch-state.jsonBmemory/events/task-2553.parallel-runtime-registry.batch-state.jsonceZdZdZy)FrozenWriteRefusedzERaised when emission targets a frozen / non-allowlisted path (9-R.1).N)__name__ __module__ __qualname____doc__9/home/jay/workspace/anu_v3/runtime_batch_state_updater.pyr r )sOrr cvtjt|jj SN)hashlibsha256r read_bytes hexdigest)paths r_sha256r-s' >>$t*//1 2 < < >>r) contamination prior_versioncXt|xsg}hd|jD cic]\}} || jd} }} t|xr"t fd| j D} t d| j D} t d|j D} | s|rd}n | r| sd}nd}| xr| xr| }|d d d |rd nd d}idtdddtd|dzdd ddd|d|d|d|ddd|d|d |d!|d"|d#d$d%d&d'd(d)iScc} }w)*uPure builder — derives the additive PROPOSAL doc. Writes NOTHING. `prior_version` lets callers chain versions additively (regression 13); the emitted doc is versioned and never overwrites durable v1. >TRACK_MISMATCHNO_CRON_TASK_DONEDUPLICATE_CALLBACK_IGNOREDNORMAL_COLLECTOR_COMPLETEDRESULT_READY_NO_NORMAL_CALLBACKclassificationc3&K|]}|v ywrr).0cterminal_statess r z!build_proposal..Ks/!"_/sc3&K|] }|dk( yw)rNr)r&r's rr)z!build_proposal..Ns"# sc3`K|]&}|jdijdd(yw) next_actionblockingFN)get)r&recs rr)z!build_proposal..Qs0   r"&&z59s,.RECOMMEND_HOLD_FOR_CHAIRRECOMMEND_BATCH_ACCEPTRECOMMEND_CONTINUE_LOOPz4runtime_reconcile_checkpoint.batch_state (read-only)Fu&CHAIR (§7/§9 closeout 확정 금지)utall tracks terminal & no mismatch/contamination — closeout PROPOSED only; chair confirmation still required (§7).uTnot all tracks terminal or mismatch/contamination present — closeout NOT eligible.)eligible derived_from confirmedauthority_requiredreasonschema artifact_kindADDITIVE_VERSIONED_PROPOSALbatch_idversionsupersedes_durable_v1durable_v1_writez(ZERO (read-only provenance input, 9-R.1)source_fixturesource_fixture_sha256frozen_batch_state_v1_reffrozen_batch_state_v1_sha256frozen_couplingz9read-only provenance only; zero mutation/coupling (9-R.1)generated_ts_ksttracksrbatch_next_actioncloseout_proposalwrite_authorityu{PROPOSAL artifact only — checkpoint performs zero write to durable v1 / coordinator / any existing batch-state (§7/§10)callback_paths_statusu'documented & NOT disabled (§2, reg 17)u'documented & NOT disabled (§2, reg 18)u$compatible & unchanged (§2, reg 19))primary_callback_pathfallback_safety_pathcancel_on_success) listitemsr.boolallvaluesanySCHEMABATCH_ID) track_recordsr@rA frozen_v1_reffrozen_v1_sha256rErrtidr/classifications all_terminal any_mismatch blocking_anyrGcloseout_eligiblerHr(s @rbuild_proposalr_1s! ,"-MO 8E7J7J7L+33SWW% &&O &3/&5&<&<&>/,L'6'='='?L '')L }6 l45%O\)9O->O%NF! F %  & 6  H  =1$      F   .  !6  $]  '(8   G  ,  -  ! " .# $ .% &  M) . %N$M!G" / KsD&ct|j}t|j} |j|j}|t vrt d|d|tk7rt d|dtd|jjddtj|d d }|j|d zd t|S#t$r}t d||d}~wwxYw)uiHard-guarded emitter — the ONLY function here that touches disk. Refuses (FrozenWriteRefused) unless `out_path` resolves to exactly ``/memory/events/task-2553.runtime-reconcile-checkpoint .batch-state.json`` (9-R.1 allowlist). Never overwrites durable v1 or any other batch-state-class file. Returns the written file's sha256. zemit path escapes repo_root: Nz refused: z- is a frozen/durable batch-state file (9-R.1)z$ not the allowlisted PROPOSAL path (z ) (9-R.1)T)parentsexist_okF) ensure_asciiindent zutf-8)encoding)rresolve relative_toas_posix ValueErrorr FORBIDDEN_EMIT_RELPATHSALLOWED_EMIT_RELPATHparentmkdirjsondumps write_textr)docout_path repo_rootrelexcpayloads remit_runtime_batch_staterysY'')IH~%%'H""9-668  %% uI J   "" u$%Y 0   OO$6jj5;G $9 8 %  +H: 6  sC C<(C77C<)rrreturnstr)rVzDict[str, dict]r@r{rAr{rWr{rXr{rEr{rzOptional[List[dict]]rintrzDict[str, object])rsr}rtrrurrzr{)r __future__rrrppathlibrtypingrrrrTrUrm frozensetrl RuntimeErrorr rr_ryrrrrs # '' = AL $%PP?+/X"XX X  X  XX(XXXv" """ "r