3j.5DdZddlmZddlmZddlmZddlmZm Z ddl m Z ddl m Z ddlmZmZmZmZmZmZmZmZdd lmZd Zd Zed ed edededededediZehdZedGddZdddddddd d!Z d)d"Z!d)d#Z"d$e d% d*d&Z#d)d'Z$y()+uanu_v3.checkpoint_turn_boundary_sweep — PURE READ-ONLY turn-boundary sweep. task-2553+43 STEP 3 (회장 GO) — runtime checkpoint operationalization 후보. OPERATIONALIZATION CANDIDATE ONLY. This module is the read-only detection *candidate* that ANU *could* call at a turn boundary so a finished +31 checkpoint state (drift / stale / recovery / NO-CRON done / result-ready with no normal callback) is enumerated WITHOUT a chair question. It does NOT wire itself anywhere; actual operational wiring is a separate post-task chair GO (task §5 "실 운영 결선 적용" forbidden). DESIGN BOUNDARY — 9-R.1 Layer A (task §1/§3/§4/§5; regression static+dynamic): * PURE read-only function — checkpoint state read -> candidate enumeration * ZERO write / cron register|remove / merge / PR / dispatch / closeout * idempotent — N calls with identical inputs return identical output * +31 runtime_reconcile_checkpoint.py + recovery layer consumed READ-ONLY (import + emit=False entrypoint only; emit=True is NEVER reached) * recovery-not-primary invariant asserted via the +32 sidecar (read-only): callback primary / fallback safety / cancel-on-success paths preserved, never replaced (task §5 "fallback safety path 제거" / "primary callback 대체물로 격상" forbidden) * 9-R.1 Layer B (executor §8 completion callback cron) is a SEPARATE process-lifecycle signal fired by the executor via external cron tooling — NOT this module's behaviour and NOT this module's side-effect. This module never registers/removes a cron, never writes a file, never merges, never opens a PR, never mutates the +31 frozen original. ) annotations) dataclass)Path)DictList)RuntimeReconcileCheckpoint)DEFAULT_STALE_SECONDS)NO_CRON_TASK_DONERESULT_READY_NO_NORMAL_CALLBACKNORMAL_COLLECTOR_COMPLETEDDUPLICATE_CALLBACK_IGNOREDTRACK_MISMATCHRUNNINGFALLBACK_PENDINGSTALE_OR_BOT_STUCK_CANDIDATE)+runtime_reconcile_checkpoint_recovery_layerz/anu_v3.checkpoint_turn_boundary_sweep.result.v1z9anu_v3.checkpoint_turn_boundary_sweep.wiring_candidate.v1NO_CRON_DONE_CANDIDATERECOVERY_CANDIDATESTALE_CANDIDATEDRIFT_CANDIDATEBENIGN_NORMAL_COMPLETEDBENIGN_DUPLICATE_IGNOREDINFLIGHT_FALLBACK_PENDINGINFLIGHT_RUNNING>rrrrT)frozenc`eZdZUdZded<ded<ded<ded<ded<ded <ded <d d Zy )SweepCandidatez7One read-only enumerated turn-boundary sweep candidate.strtask_idclassificationcandidate_typebool actionablerecovery_eligibleterminalrecommended_signalc|j|j|j|j|j|j |j dS)Nrr r!r#r$r%r&r()selfs :&  ? ? A  > > @ r,c  ddddddddddddd S)Nrz*import + checkpoint_entrypoint(emit=False)FuLayer A (9-R.1): pure read-only enumeration. The §8 executor completion callback cron is Layer B — a separate process-lifecycle signal fired by the executor via external cron tooling, NOT this module's behaviour.) write cron_register cron_removemergeprdispatchcloseout_confirmcallback_collector_path_touchedfrozen_plus31_mutationconsumes_plus31_viaemit_true_reachednoter5r5r,r*_zero_side_effect_proofrPs2+,"#K"= r,)generated_ts_kst stale_secondscpt|}t|}t||}|j||}|d}|d}g}t|D]} || } t | d} t j | d} |jt| | | | tvt| j ddt| j d dtj | d  i} |D]7}| j|jgj|j9|Dcgc]}|js|j}}t d d dd|t |dddd|Dcgc]}|j#c}| |t%|t%|t't)dScc}wcc}w)uMPURE read-only turn-boundary sweep. Reads +31 checkpoint state for ``fixture_path`` via the read-only ``checkpoint_entrypoint`` (emit=False) and enumerates drift / stale / recovery / NO-CRON-done / result-ready candidates. Returns a fully deterministic document — identical inputs => byte-identical output (idempotent). Writes NOTHING, registers/removes NO cron, merges NOTHING. ``generated_ts_kst`` is passed straight through (caller-supplied, default empty) so the function holds no internal clock — a precondition of the idempotence guarantee. )rS)rRdecision_packet track_recordsr UNKNOWNr$Fr%rQr( task-2553+43CHECKPOINT_TURN_BOUNDARY_SWEEP READ_ONLYz$A_DELIVERABLE_PURE_READ_ONLY (9-R.1)z1anu_v3.runtime_reconcile_checkpoint (+31, frozen)z!checkpoint_entrypoint(emit=False)z@anu_v3.runtime_reconcile_checkpoint_recovery_layer (+32, frozen))module entrypointrecovery_layer)schemarsweepmodelayerrRsource_fixtureconsumes_plus31 candidatesby_candidate_typeactionable_candidatesactionable_count tracks_totalrecovery_invariantzero_side_effect_proof)rrcheckpoint_entrypointsortedr_CANDIDATE_TYPEgetappendr _ACTIONABLEr"_RECOMMENDED_SIGNAL setdefaultr!rr#SWEEP_RESULT_SCHEMAr+lenrBrP) repo_root fixture_pathrRrSckptpacketdecisionrVrdtidrecr ctypeby_typecr#s r*sweep_turn_boundaryrs&YI %L &i} MD  ' ''7(F'(H%-o%>M')Jm$  C S!123##NI>.)  +"377+>#FG#''*e45266ubA   %'G C1++R077 BC&0@1<rs 8#!J   LG?/#%9 "3% 9 :1    $   6 MOKGI J!M;  (04 III I  I  IXJr,