K t|dd} |D]@}|j}|s tj|}t |ts=|B |jy#t$rYywxYw#t $rYowxYw#|jwxYww)uJSONL 파일을 라인 단위로 스트리밍하며 파싱된 dict 를 yield (bounded read). 전량 메모리 적재 금지 — 호출부는 일치 시 즉시 break 하여 조기탈출한다. (a) 파일 부재(FileNotFoundError) → 빈 제너레이터(정상 초기 상태). (b) 권한/IO 오류 등 기타 open 예외 → 상위로 전파 → 호출부 fail-closed (LEDGER_UNREADABLE → BLOCK). 손상된 개별 라인은 skip(append-only 부분쓰기 허용). rXrYrZN) r\r_stripr]loadsrwr<r=close)rorblineobjs rD_iter_jsonl_linesrs sW -  D::r?)es rD_get_event_epochrsM!| 7$ $ AEE$O, --   s 8 AA)ra ledger_pathrOlive_lock_presentrcircuit_marker_path p0b_flag_pathc !"#|t}|t}t|t}|t}t |d"t |d}t |d} |d| !| t }t|#d!"#fd } dfd } | tvr| | ttS t|D]X} t| jdd "k(s"t| jdd |k(sA| | ttcStD]\} t| jd d !k(s"t| jdd tk(sE| | ttcS |#t$j&j)t*}|r| | t,t.S t1|} | jd g}t5|t6sg}|j9}|Dcgc]}|t;|z d ks|}}|Dcgc]}|t;|z d ks|}}t=|t>k\st=|t@k\r| | t,tBS| jdi}| jdi}t5|tDsi}t5|tDsi}tG"}tI|j"d}tI|j|d}|tJk\s |tLk\r| | ttNStPd z}|Dcgc]}|t;|z |ks|}}t=|}tSd|D}|dkDr||z nd}|tTk\xs |tVk\}|r t$j&jY|xsd}t%jZ|dt]|dd5}|j_#dzdddt$j&j)|r) t]|dd5}|j_dddd| | t`tbS|dz|"<|dz||<|je#|"dd|| d<|| d<|| d < tg|| | ttj} | | S#t $r| | tt"cYSwxYw#t $r| | tt2cYSwxYwcc}wcc}wcc}w#1swYxYw#t $rY.wxYw#1swYxYw#t $rYwxYw#t $r| | tthcYSwxYw) uspawn 가능 여부를 평가하고 Decision dict를 반환한다. 차단 순서(첫 차단에서 멈춤, 모든 결정은 spawn_decisions.jsonl에 append): 1. terminal-only HARD GATE: terminal_state가 TERMINAL_STATES에 없으면 BLOCK 2. dedup: 동일 key가 이미 ALLOW로 기록돼 있으면 BLOCK 3. single-flight: live_lock 존재 시 QUEUE 4. rate-limit: 분당/시간당 초과 시 QUEUE 5. loop-budget: task/family 누적 ALLOW 초과 시 BLOCK 6. circuit-breaker: 윈도우 내 spawn/실패율 초과 시 TRIP 7. 전부 통과 → ALLOW 반환 구조: dict(decision, reason, task_id, key, ts) NrLhead_shaterminal_state|decisionc$t||S)N)rreasonrLkeyr)r=)rrrrLts_strs rD_make_decisionz&evaluate_spawn.._make_decisions   rFc t||S)u+spawn_decisions.jsonl에 append 후 반환.)r)drs rD_record_and_returnz*evaluate_spawn.._record_and_returns+rFrHrr<iper_task per_familyrc3^K|]%}t|jdddk(s"d'yw)outcomerHfailrN)r>r?).0rs rD z!evaluate_spawn..Js'U1QUU9b5I1Jf1TQUs#--rfTrgrkrYrZrr rallow)rrrLr)rr>rr>returnr=)rr=rr=)6r7r5r6r9r:rErRrVr)rr+rr>r?r,rrwr3rnroexistsr8rr-rdr1r<list timestamprlenr"r#r.r=r!intr$r%r/r&sumr'r(rprqr\rrr0appendr}r2r*)$rArarrOrrrrrrrrentryryrnow_tsr events_1min events_1hourrrfamily task_count family_count window_sec events_windowwindow_spawn_count fail_count fail_ratecircuit_trippedrzrb decision_recrrLrs$ ` @@@rDr r sF2- * ."4( y)4Gy*5Hy*:;NJa' (C {j #YF  _,!.8K"LMMS&{3 SEEIIi,-8EIIj"56(B).@P*QRR S '~6 SEEIIeR()S0EIIj"56%?).@P*QRR S GGNN+<=!.8P"QRRU!-0<<"-F fd # ]]_F &L!2B12E)E)KALKL%N!2B12E)E)MANLN ;<'3|+< +M!.8L"MNN ||J3H||L"5J h % j$ ' ' "Fx||GQ/0Jz~~fa01L]"lo&E!.8L"MNN$b(J &U1&3CA3F*F**TQUMU]+U UUJ5G!5K00QTI // * ) ) 77??#67>3D KKt ,)3A 'Q & ' 77>>- ( -w?'1GGI&' ".7J"KLL$aHW%)Jv MM&WQXYZ%HZ'H\#HXV}h/"%6L l ++{ S!.8P"QRRS U!.8R"STTUMN,V ' '    ''  & V!.8S"TUUVs,R$ R$)R$-R$0"R$R$,R$- S 0S0S0S5(S5(S:?S:AT S?"T T(T*T(? T8$ SS S-,S-?T T TTT%!T(( T54T58 UUc |jdr|dddz}tj|}|j |j t j }|jS#t$rYywxYw)uGISO8601 UTC 문자열을 epoch(float)로 변환. 파싱 실패 시 0.0.ZNz+00:00)tzinfor) endswithr fromisoformatrrvrrPrrw)rrUs rDrrzso  ??3 CR[8+F  # #F + 99 8<<0B||~ sA)A,, A87A8)rH)rBr>rCr>rr>)rLr>rr>)rr)rUrrr>)rar>rr=)rar>ryr=rNone)rr>rr=rr)ror>)rr=rr)ra Optional[str]rrrOzOptional[datetime]rzOptional[bool]rrrrrrrr=)rr>rr)6__doc__ __future__rr]rnrIrrrrtypingrr"r#r$r%r&r'r(r)rrrrr*r+r,r-r.r/r0r1r2r3r4rojoinr5r6r7r8r9r:__all__rEr!rRrVrdr}rrrr rrQrFrDrs # '   > # )&.**)341''',,~xKhi'',,~xJab'',,~xJ_`'',,~xJbc'',,~xJhi'',,~xJ^_ 4=(& - &, 8."$(!%"(,$()-#'n,!n, n,  n, & n,"n,'n,!n, n,b rF