3jUdZddlmZddlZddlmZmZddlmZm Z m Z m Z m Z ddl mZmZmZmZddlmZmZmZddlmZdd lmZmZmZmZmZmZdd lm Z d Z!d Z"eZ#d Z$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1 ddl2m3Z4e5e6e4Z3de7d<d.dZ9ed !Gd"d#Z:ed !Gd$d%Z;eGd&d'Z<Gd(d)Z=d*d+ d/d,Z>gd-Z?y#e8$rdZ3YcwxYw)0um anu_v3.runtime_event_loop — ANU runtime event loop driven by the durable 4-tuple registry (task-2553+54, 회장 정정·결정). 회장 §1 verbatim: "우리가 원하는 것은 사후 복원이 아니라 즉시 진행이다. normal callback durable-success → registry write-back → ANU runtime event loop가 즉시 감지 → batch coordinator 취합 → 다음 작업 dispatch 또는 consolidated summary 생성까지 자동 진행." Problem (회장 §2 diagnosis): +44 durable registry, +47 read-only event trigger, +49 self-chain quarantine selector and +53 durable-success write-back / batch-settle evaluator each exist, but there was no single *runtime event loop* that interprets a durable-registry append/update as a progress event and immediately drives the next step (single-task next_action / batch all-settled / consolidated summary candidate / next-phase ANU-key dispatch candidate) without waiting for a fixed-time gate or a dead-man fallback. This module is that loop. It is a pure, read-only consumer (9-R.1): * ``callback_4tuple_index.jsonl`` is the **state source** — read-only. This module NEVER writes the registry; the durable-success write-back is +53's sole responsibility (no new write-back logic here). * ``schedule_history`` is an audit log — it is NEVER a progress trigger. * ``cron-list`` is the current reservation state — NEVER an authority. * a fixed-time gate / dead-man fallback is a missed-callback safety net — NEVER a progress trigger. Offering one as the progress trigger is a hard FAIL (``FORBIDDEN_TRIGGER_SOURCE``, 회장 §3/§5 verbatim). * the ONLY accepted progress trigger is a durable-registry ``registry_completed_event`` (a normal-callback durable-success append/update). Reuse, not re-implement (회장 §10 9-R.1): * +44 ``anu_v3.callback_4tuple_registry`` — read-only registry scan. * +47 ``anu_v3.callback_event_trigger.CallbackEventTrigger`` — the single-task next_action resolver (already registry-event-driven). * +49 ``anu_v3.authoritative_verdict_selector`` / ``anu_v3.self_collector_guard`` — self-chain verdict is permanently quarantined; a non-ANU collector record is HOLD. * +53 ``anu_v3.batch_settle_writeback.evaluate_batch_settle`` — batch all-settled over the durable-success write-back lines. Authority boundary (회장 §2.12 / §8): the loop only *detects / evaluates / proposes*. It has NO dispatch / merge / write authority. Every next-phase ANU-key dispatch and every consolidated summary is emitted as a **proposal JSON only** — zero auto-dispatch / auto-merge / auto-closeout. Idempotency (회장 §2.9 / §2.10): the loop is a pure deterministic function of the registry state. Each progress event has a deterministic ``event_id``; duplicate events (e.g. a dead-man-fired duplicate COMPLETED line, or the same event scanned twice) are de-duplicated so the loop yields exactly one next_action / one consolidated summary / one dispatch candidate per task/batch and never a duplicate. Layer A / NO-CRON: ZERO cron register/remove, ZERO dispatch, ZERO merge, ZERO ``cokacdir`` / ``subprocess`` exec, ZERO registry write. ) annotationsN) dataclassfield)DictListOptionalSequenceTuple)AUTHORITATIVE_PASSCOLLECTOR_ROLE_ANU VerdictRecordselect_authoritative_verdict)TERMINAL_WRITEBACK_VERDICTS DURABLE_SUCCESS_WRITEBACK_SCHEMAevaluate_batch_settle)Callback4TupleRegistry)CallbackEventTriggerFORBIDDEN_PROGRESS_TRIGGERSNEXT_ACTION_READYTRIGGER_DEAD_MANTRIGGER_FIXED_TIMETRIGGER_REGISTRY_COMPLETED)guard_self_collector_sessionzanu_v3.runtime_event_loop.v1zruntime_event_loop_result.v1normal_callback_durable_successdurable_success_writebackregistered_no_progressself_chain_quarantined_ignorednon_anu_collector_holdrWAIT ALL_SETTLEDNO_REGISTRY_NO_ACTIONFORBIDDEN_TRIGGER_SOURCETRACK_MISMATCHHOLD_FOR_CHAIRnoneproposal)DEFAULT_ANU_KEYSzTuple[str, ...]r'ctjdjd|Djdj S)N|c3:K|]}|dn t|yw)Nstr).0ps 0/home/jay/workspace/anu_v3/runtime_event_loop.py z_sha..s<qyc!f,> r>se=L*.-.&*m*/3}30c07;4;.2J+2#'M='"&L-&r;r>cBeZdZUdZded<ded<dZded<dZd ed <y) BatchSpecuA parallel batch watched by the loop. ``expected_tracks`` = sequence of (track_id, task_id). ``next_phase`` (optional) declares the post-consolidation ANU-key dispatch — proposal only.r.batch_idzSequence[Tuple[str, str]]expected_tracksNr@ this_track_idrFrH)rKrLrMrNrOrTrHr(r;r1rQrQs)>M..#'M='.2J+2r;rQceZdZUded<ded<ded<ded<ded<ded <ded <ded <ded <ded <ded<ded<ded<ded<ded<ded<ded<ded<ded<eeZded<eddZd dZ y)!RuntimeEventLoopResultr.schemagenerated_at_kst registry_pathr@progress_triggerverdictboolfixed_time_used dead_man_useddead_man_signal_observedfallback_pending_non_blocking authority action_modeList[Dict[str, object]]events_observedintduplicate_events_suppressedsingle_task_results batch_resultsconsolidated_summary_candidatesdispatch_candidatesquarantined_eventshold_for_chair)default_factoryz List[str]reasonsc2|jttfvSN)r[LOOP_FORBIDDEN_TRIGGERLOOP_HOLD_FOR_CHAIRselfs r1okzRuntimeEventLoopResult.oks|| " $   r;cid|jd|jd|jd|jd|jd|j d|j d|jd |jd |jd |jd t|jd |jdt|jdt|jdt|j dt|j"t|j$|j&t|j(dS)NrWrXrYrZr[r]r^r_r`rarbrdrfrgrhrirj)rkrlrn)rWrXrYrZr[r]r^r_r`rarblistrdrfrgrhrirjrkrlrnrss r1to_jsonzRuntimeEventLoopResult.to_jsons{ dkk  5 5  T//   5 5  t||  t33   T//  '(E(E  ,22    4++  tD$8$89  *4+K+K "4(@(@#A! " T$"4"45# $ .t440% * "4(@(@#A+ ,#'t'>'>"?"11DLL)1  r;Nreturnr\)rzDict[str, object]) rKrLrMrOrrwrnpropertyrurxr(r;r1rVrVs K## L""#''N,,!$$00**%<<00//t4GY4    r;rVceZdZdZed ddZddZddZ ddZ ddZ ddZ dd Z d d e d d d  ddZ y)RuntimeEventLoopa"Durable-registry-driven runtime event loop (read-only consumer). The loop never writes the registry, never registers/cancels a cron, never dispatches/merges. ``run`` is idempotent: repeated runs over the same registry state yield an identical result and zero side-effects. )anu_keysc`||_td|D|_t||_y)Nc3&K|] }|s| ywrpr()r/ks r1r2z,RuntimeEventLoop.__init__..s7AQa7s)registrytuplerr_trigger)rtrrs r1__init__zRuntimeEventLoop.__init__s) ! 777 ,X6 r;cj |jjjS#t$rYywxYw)NF)r ledger_pathis_fileOSErrorrss r1_registry_presentz"RuntimeEventLoop._registry_presents2 ==,,446 6  s #& 22cddl}g} |jjjs|S|jjj d}|j D]I}|j}|s |j|}t|ts9|j|K|S#t $r|cYSwxYw#t$rYjwxYw)uAll raw JSONL lines (fail-safe; corrupt lines skipped). The loop only READS — it never appends here (no +53 write-back).rNr3)encoding) jsonrrr read_textr splitlinesstriploads ValueError isinstancedictappend)rtrouttextrawds r1 _all_lineszRuntimeEventLoop._all_liness ') ==,,446 ==,,666HD??$ C))+C JJsO!T" 1    J   s(%B2&B2;C2 C?C CCc t|jdxsd}t|jdxsd}t|jdxsd}t|jdxsd}t|jdxsd}t|xr||k(}|r|tk7rt|d|dgfSt |||xst| }t td |tvrd n|xsd ||||xst|d | g||j} |jr"| jtk7s| jdkr&t|d| jd|jdgfSt|dgfS)aInterpret a +53 durable_success_writeback line as a progress event, routing self-chain / non-ANU collectors through +49. Returns (event_kind, reasons). Self-chain origin -> permanently quarantined (ignored as a progress trigger). collector_role != ANU -> HOLD. Independent-ANU AUTHORITATIVE_PASS -> a valid durable- success progress event. r?r,rIrJcollector_roleauthoritative_verdictz: collector_role=ut != 'ANU' — non-ANU collector record is NOT a progress trigger; routed to HOLD via +49 guard (회장 §8 / reg 9).)rJrIris_executor_self_sessioncollector_resultPASSFAILindependent_anu) kindr[r?rJrIrsession_is_executor_selfclaimed_origindetail)r?rzU: +49 selector/guard did NOT confirm an independent-ANU AUTHORITATIVE_PASS (selector=z , guard_ok=ug) — self-chain verdict permanently QUARANTINED, ignored as a progress trigger (회장 §5.D / reg 8).uq: independent-ANU AUTHORITATIVE_PASS durable-success write-back — valid registry progress event (회장 §2.1).)r.getr\r EVENT_NON_ANU_HOLDrrr rrruclassificationr independent_anu_countEVENT_SELF_CHAIN_QUARANTINEDEVENT_DURABLE_SUCCESS_WRITEBACK) rtliner?rIrJrr[ self_sessiongsels r1_classify_writeback_eventz*RuntimeEventLoop._classify_writeback_eventsdhhy)/R0DHH_5;< 488N39r: TXX&67=2>dhh67=2>M*L} /L n0BB%),^,>?EE(  )%')?-?%1   ++"==#!+V#!-"/#1#G5G-9#4"  ]]# &tts))-??  % % )/)@%%( ADD6:222 /iK K1   r;c Jg}g}t}d}|jD]}t|jdxsd}|tk(r|j |\}}t ||jd|jd|jd|jd|} | |||jd|jd|jd|jd |jd|d } | |vr|d z }|j| |ttfvr|j| |j| 2t|jd xsd} | d k(rtnt}t |xsd|jd|jd|jd| |} | ||xsd|jdd| |jdgd} | |vr|d z }|j| |j| |||fS)uScan the registry and build the de-duplicated progress-event list (+ quarantined list + duplicate-suppressed count). Idempotency (회장 §2.10): each event has a deterministic ``event_id``; an identical event observed again (a dead-man-fired duplicate COMPLETED line, or the same registry scanned twice) is suppressed — counted once, never re-driven.rrWr,r?rR writeback_idwriteback_classificationtrack_idr) event_id event_kind schema_kindr?rRrrrrnrstatus COMPLETEDz callback_4tuple_ledger_record.v1 dispatch_idnormal_collector_cron_idNrole)rrrr?rRrrrn) setrr.rrrr:addrrr%EVENT_NORMAL_CALLBACK_DURABLE_SUCCESSEVENT_REGISTERED_NO_PROGRESS) rtevents quarantinedseen suppressedlnrWrwhyeidrecrs r1 _build_eventszRuntimeEventLoop._build_eventsWs8+-/1  //#H #B)/R0F99 ::2> cFF9%FF:&FF>*FF56 !$"&#)!vvi0 "z 2 "z 2-/VV/.1321 #$;!OJ 0& &&s+MM#& RVVH-34,:5 @@FF9%FF=)FF56 !$"&D"D!vvi0 $$FF6N! $;!OJ  c"QH #R{J..r;c t|j}dttd||dt |j|t |t |dd S)uOBuild a next-phase ANU-key dispatch **candidate** (proposal). The loop has NO dispatch authority. The candidate names the independent-ANU key set as the only legitimate owner; an unresolvable ANU key set is surfaced (never a silent self-dispatch — 회장 §5 verbatim forbids executor self-dispatch).z/anu_v3.runtime_event_loop.dispatch_candidate.v1FTuPROPOSAL ONLY — next-phase dispatch must be enacted by an independent ANU-key session; the event loop performs ZERO auto-dispatch / merge / closeout (회장 §2.6/§2.12/§8). executor self-dispatch is forbidden (회장 §5).) rWrarb auto_executedsource source_idanu_key_owner_requiredranu_keys_resolvablerH gate_evidencenote)r\rAUTHORITY_NONEACTION_MODE_PROPOSALrwr)rtrrrHranu_resolvables r1_dispatch_candidatez$RuntimeEventLoop._dispatch_candidatesVdmm,G'/""&*T]]+#1z*!-0D  r;c dttddd||jd|jd|jd|jdd d S) Nz;anu_v3.runtime_event_loop.consolidated_summary_candidate.v1F CANDIDATE$CONSOLIDATED_SUMMARY_CANDIDATE_READYevaluated_at_basis all_settledall_authoritative_pass track_statesuPROPOSAL ONLY — consolidated summary candidate generated by the runtime event loop on the normal-callback durable-success event (회장 §2.5). No auto-closeout.) rWrarbrrrrRgenerated_basisrrrr)rrr)rtrR settle_jsons r1_summary_candidatez#RuntimeEventLoop._summary_candidates_'/"< */CD&??=9&1oo('(OON;B!  r;r(Fr,) single_tasksbatchesprogress_trigger_sourcedead_man_signalrXc R g}|tvr|jd|dtdtdtd t d1idt d|dt|jjd d d td |tk(d |tk(d|dddtdtdgdddgdgdgdgdgddd|S|js|jdt d1idt d|dt|jjd td td dd dd|dddtdtdgdddgdgdgdgdgddd|S|r|jd|j\}}} | r|j| d |D]=} | j!dg} t#| t$s&|j'd!| D?g} g} g}d}t)}|D]}|j*|vr|j-|j*|j.j1|j*|j2|j4|j6t|j8|j:|"}|j=}| j||j|j>|j>d#k(r d}|j|j*d$|j@s |j>tBk(s|jDs-| j|jGd%|j*|jD|jH|jJ|jLd&'g}g}t)}|D]}|jN|vr|j-|jNtQ|jNt%|jR|jj|jT(}|j=}|j||jVr|jXr|jtZ|j|j]|jN||jd)|jNd*|jDs| j|jGd+|jN|jD|j^|jV|jXd,'z|jt`|jd)|jNd-tc|jddtct%|jRd.|rtf}n>tZ|vrtZ}n/tB|vrth}n |rt`}nt`}|jd/|jd0t d1idt d|dt|jjd td |d dd dd|dddtdtd|d| d| d|d|d| d|d|d|S)2uInterpret durable-registry append/update as progress events and immediately drive the next step (회장 §2 1~12). * ``progress_trigger_source`` MUST be ``registry_completed_event``. A ``fixed_time_gate`` / ``dead_man_fallback`` -> hard FAIL (``FORBIDDEN_TRIGGER_SOURCE``; 회장 §3/§5 verbatim, reg 10). * a ``dead_man_signal`` is recorded as observed but is NEVER promoted to a progress trigger (회장 §3, reg 6). * a missing registry -> ``NO_REGISTRY_NO_ACTION`` recovery state, no action (reg 11). * single task: +47 ``CallbackEventTrigger.scan`` -> READY/WAIT; identity mismatch -> ``TRACK_MISMATCH`` (reg 1/12). * batch: +53 ``evaluate_batch_settle`` -> WAIT (partial) / ALL_SETTLED (every track durable-success). all-settled & all-AUTHORITATIVE_PASS -> consolidated summary candidate (reg 2/3/4/15/16). * a declared ``next_phase`` -> ANU-key dispatch **candidate** (proposal only, reg 13/14; 회장 §2.12/§8). * fallback/dead-man pending is NON-blocking (reg 5). * idempotent across repeated runs and duplicate events (reg 6/7). zprogress_trigger_source=z is a /u9-class trigger — FORBIDDEN as a progress trigger; only uV (a durable-registry append/update) drives progress (회장 §3/§5 verbatim, reg 10).rWrXrYrZNr[r]r^r_r`TrarbrdrfrrgrhrirjrkrlFrnudurable registry absent — NO action; this is the correct fail-safe recovery state (defer to schedule_history audit + canonical artifact, never a misjudged progress). The registry is the state source; its absence is not a trigger (회장 §3, reg 11).ua dead-man signal was OBSERVED but is EXPLICITLY NOT promoted to a progress trigger — missed-callback safety net only (회장 §3, reg 6).u duplicate registry event(s) suppressed (deterministic event_id) — idempotent: a re-scanned / dead-man-duplicated event is counted once, never re-driven (회장 §2.10, reg 6/7).c32K|]}t|ywrpr-)r/xs r1r2z'RuntimeEventLoop.run..fs9!s1v9s)r?rArBrCdependency_trigger_sourcerErGrr#u: registry identity mismatch -> TRACK_MISMATCH/HOLD (an unrelated track's callback is never cited as progress; 회장 §6, reg 12). single_task)trigger_sourcer]r^)rrrHr)rRrSrrTzbatch u: 3/3 (all) tracks durable-success settled & every verdict AUTHORITATIVE_PASS — consolidated summary candidate generated immediately on the normal-callback durable-success event (회장 §2.4/§2.5, reg 3/4/15/16).batch)rrrz: u tracks settled — WAIT (not all-settled). A fallback/dead-man pending state does NOT block a completed track's progress (회장 §2.7, reg 2/5).uno single-task / batch spec supplied — loop scanned the registry, recorded progress events, took no action (read-only consumer).uschedule_history=audit only · cron-list≠authority · durable registry=state source · event loop=progress trigger · fallback/dead-man=safety net (NOT a progress trigger). All outputs are proposals (NO auto-dispatch/merge/write — 회장 §2.12/§8).r()5rrrrPROGRESS_TRIGGERrV RESULT_SCHEMAr.rrrqrrrLOOP_NO_REGISTRYrrrrwextendrr?rrscanrArBrCrErGrxr[readyrrHrrr]r^rRrrSrTrrLOOP_ALL_SETTLEDrr LOOP_WAITlentracks_settledLOOP_TRACK_MISMATCHLOOP_NEXT_ACTION_READY)rtrrrrrXrnrrrq q_reasonssingle_resultsrjverdictshold seen_taskspecrrjrhsummary_candidates seen_batchbsettlesjr[s r1runzRuntimeEventLoop.runs<  #&A A NN*+B*EV%(*:)=>=#&'EE *$!1"$--";";<"&  / ,/AA,/??*9/3)1 !#!"-.#$%'%&!'(13)*%'+,$&-. %/0 1 8%%' NN0 *$!1"$--";";<"2  )  !& $*9/3)1!#-.%'! 13!"%'#$$&%& %'( ) .  NN0 +/*<*<*>' Z  NN,33   :Ai,I)T*9y99 : 3579 !e  ( D||y( MM$,, ' "" %)%>%>!%!6!6*.*H*H*:!%!6!6$($<$< /# AB  ! !" % OOAII &yy,,||n%DD II!22OO#**,,,"&,,#'??./.>.>/0/@/@-.__' -  ;( V24 68"u 0 AzzZ' NN1:: &* $Q%6%6 7 MM55oo F !B   $!!f&C&C 01"))++AJJ;QZZL)33<<'..00#*&'jj'(||6<6O6O/5/A/A$*$A$A + 1   *QZZL60012!4 1 12345''S0 f )G  )&G ( *,G GG NN"    &   - dmm778 .    "    &5 +/ % - # )3 !/ ( -?! "!4# $ +% & ' ()  r;N)rrrz Sequence[str]rzNonery)rzrc)rr{rzzTuple[str, List[str]])rzz,#  " "#+.." r;) LOOP_SCHEMArrrrrrrrrrrrqrrrrrr>rQrVr~r )r9objectrzr.)r rVrXr.rzr{)@rN __future__rr4 dataclassesrrtypingrrrr r %anu_v3.authoritative_verdict_selectorr r r ranu_v3.batch_settle_writebackrrranu_v3.callback_4tuple_registryranu_v3.callback_event_triggerrrrrrranu_v3.self_collector_guardrrrrrrrrrrrrrrqrrrrr dispatch.callback_owner_enforcerr' _ANU_KEYSrsortedrO Exceptionr:r>rQrVr~r __all__r(r;r1rs}8r#(88  - . .)J%"=7?--   *3&&! ).fY.?(@o@  $'''& $333 7 7  7 tW W v@B  " 9<    cs9C,,C65C6