Oj3UdZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z ddl mZddlmZddlmZmZmZmZmZmZdd lmZdd lmZerdd lmZmZdd l m!Z!dd l"m#Z#ddl$m%Z%m&Z&m'Z'm(Z)m*Z*m+Z+ddl,m-Z.m/Z/m0Z0m1Z1ejde3Z4dZ5e6e7d<GddeZ8edZ9e dGddZ:dhZ;deedey)uStepRunner 베이스 클래스 — 모든 파이프라인 단계의 실행 프레임워크. 각 단계는 이 클래스를 상속하여 _execute()만 구현하면 됨. 게이트, 체크포인트, 무효화, Opik 추적을 자동 처리. N)contextmanager) dataclass)datetimetimezone)Enum)Path)AnyDictListOptionalTuple TYPE_CHECKING)text)Session)CompletionReport CleanupReport)atomic_write_json)AppError)LockKey LockOwner OwnerVerdictREGISTRY judge_ownerprocess_identity)containsget_manifest_dictget_depends_onget_all_downstream_recursiveMAX_RECOVERY_ATTEMPTSc(eZdZdZdZdZdZdZdZdZ y) ResumeActionuSResumeDecision.action — claim 후 실행 분기 결정 (V2 patch I1, spec §2.3).skip rerun_selfforce_explicitstale_running_recoveryblocknot_applicableN) __name__ __module__ __qualname____doc__SKIP RERUN_SELFFORCE_EXPLICITSTALE_RUNNING_RECOVERYBLOCKNOT_APPLICABLEJ/Users/manta/Documents/Projects/TheRoad-I1/backend/app/core/step_runner.pyr"r"=s$] DJ%N5 E%Nr4r"c#Kddlm}t|jxsi}t |j dgxsg}|j d}|d|j|||5ddddy#1swYyxYww)u스텝 하나를 Opik trace 하나로 연다. 설정이 꺼져 있으면 아무것도 안 한다(바이트 동일). 여는 데 실패해도 본 스텝은 그대로 돈다 — `open_trace` 가 None 을 줄 뿐이다. r) open_tracetags thread_idzstep:)namer8metadatar9N)app.modules.llm.opik_tracer7dictbuild_opik_metadatalistpopgetstep_id)runnerr7metar8r9s r5_step_trace_scoperEGs6 **,2 3D $* +D%I V^^$ %        sA-B /A=4 B =BB T)frozenceZdZUdZeed<eed<dZeeed<dZ eeed<dZ eeed<dZ eeed<dZ eeed <dZ eeed <y) ResumeDecisionuH판정 결과 + 사유. V3 patch B1: STALE_RUNNING_RECOVERY 시 expected_started_at + expected_run_id 동반. claim SQL 의 atomic steal 조건에서 SQL cast 없이 (text 비교만) 검증. `origin` 은 caller (run()) 가 부수효과 디스패치에 사용: - None: first-run 또는 unknown-status (cleanup 없이 execute) - "artifact_missing": completed-mismatch (record_recovery + check_exhausted + cleanup) - "prior_state": non-completed prior status (force-like log + cleanup) 후속 task (B11) 에서 CompletionReport.origin 과 통합. actionreasonNorigin prior_status prior_run_idprior_updated_atexpected_started_atexpected_run_id)r)r*r+r,r"__annotations__strrKr rLrMrNrOrPr3r4r5rHrH\sl   K FHSM #'L(3-&"&L(3-&&*hsm*)-#-%)OXc])r4rHgrounding_modeproject_configreturnc"ddlm}m}t|xsi}||}||}||j ddn||d<t j |ddd}tj|jd jdd S) uproject_config의 결정적 해시. P0-3 (Codex H2) — resume 안전성용. 같은 config면 같은 hash → 체크포인트가 만들어진 시점의 config와 현재 config가 다르면 mismatch 감지 가능. default fallback은 결정적이어야 한다. `default=str`을 쓰면 같은 클래스의 다른 인스턴스(예: ``)가 매번 다른 hash를 만들어 silent false-mismatch 회귀를 유발한다. 비-JSON 타입은 클래스명만 기록. ★**`grounding_mode` 는 값에 따라 접거나 뺀다** (`_VALUE_NORMALIZED_CONFIG_KEYS`). 실측: 이 함수는 dict 전체를 해시하므로 그 키를 넣기만 해도 지문이 움직였고 `shadow_plan` 으로 바꾸면 또 움직였다 — 검색도 산출도 안 바꾸는 관측 스위치가 하류를 통째로 다시 굽게 만든다 (계약 §12). ★**그렇다고 key 째로 빼면 안 된다.** `v2` 까지 숨겨져 **legacy 완료 CP 가 v2 진입에서 그대로 재사용된다.** 「revision/content hash 가 대신 잡는다」는 전제는 아직 구현이 없다 (그 값을 만드는 production 코드 0건). Returns 16자 md5 prefix. r)fingerprint_valueresolve_grounding_modeNrSTFc4dt|jdS)Nz )typer))os r5z%compute_config_hash..sLa)9)9(:!'R(G 'w/I Y 'D | $d+$( ! < I ;;y''0 1 ; ; =cr BBr4cDeZdZdZ dedededededeedeef d Zdfd Z d e fd Z e jd ZdZd e fdZd eefdZd eefdZedgdZded dfdZdfdZdhdddeede d dfdZded eeeeffdZedidZdjded efdZdjded efd Zd!eeefd efd"Z d#ed efd$Z!d%Z"d&d'd(d(d(d)d)d*d+ed,e d-e#ed.fd/e$d0e$d1e$d2ed3ed e fd4Z%d'd(d(d(d)d)d5d+ed-e#ed.fd/e$d0e$d1e$d2ed3ed dfd6Z&dkd7ed dfd8Z'd&ddd9d:e d;eedd?ed@e d dfdAZ)dldBe$dCe$dDe$d dfdEZ*dfdFZ+ded dfdGZ,djded eeeffdHZ-dIeded eeeffdJZ.d eeeffdKZ/d eeeffdLZ0ddMdNed eeeffdOZ1dNed eeeffdPZ2dmdQZ3dndRZ4dfdSZ5d7ed e$fdTZ6dUedVed dfdWZ7dfdXZ8d e$fdYZ9d efdZZ:ed e;fd[Zdjded eeeffd_Z?d efd`Z@ dedaeeAedbeeeefd efdcZBed efddZCy)o StepRunneru파이프라인 단계 실행기. 서브클래스는 _execute()만 구현. run()이 게이트 → 체크포인트 → 실행 → 저장 → 무효화를 자동 처리. NrB project_id episode_iddbrT opik_contextc\t|std|||_||_||_||_|xsi|_t||_ttj|_ |xsi|_ ddlm}t!|j"|z dz dz |z |z |_y)NzUnknown step: rsettings checkpointsepisodes)_step_contains ValueErrorrBrqrrrsrTrmanifestrRuuiduuid4run_idrtapp.core.configrwr projects_dir_cp_dir)selfrBrqrrrsrTrtrws r5__init__zStepRunner.__init__sg&~gY78 8 $$,2)'2 $**,' (.B - && '* 4 ( )+5 68? @ r4rUcg}t|jD]}|j|}|s|j|(|d}|dvr2|dk(rt |xsi}|j dddur\|j d}|r5|j j |durtjd|||j|d |j|d |d |r^|Dcgc]3}t |jd d xsij d |5}}tdddj|dycc}w)u의존 단계 완료 확인. blocked이면 AppError. partial cascade contract (problems.md #11 + G4.6 Phase 3 fix iter 2): - dep status == 'partial' 이고 dep manifest 의 ``allow_partial_downstream`` 가 ``False`` 면 blocked. 명시 contract 없는 dep (default True) 는 backward-compat 으로 통과. - 즉 emitter (dep step) 의 출력 contract 에 따라 cascade 제어. - **Operator override (manifest-driven)**: dep manifest 의 ``partial_override_config_key`` 가 명시되어 있고 project_config 의 동일 키 값이 truthy 면, partial 차단을 통과 (운영자가 명시적으로 partial 진행을 결정한 경우). WARNING log 동시. status completedr(partialallow_partial_downstreamTFpartial_override_config_keyudcheck_gate: dep %s partial — explicit operator override via project_config['%s']=True. proceeding.z(partial,strict)()rlabelz gate.blockedu선행 단계 미완료: , icodemessage status_codeN) rrB _get_step_runappendrrArTloggerwarningsplitrjoin) r blocked_bydepdep_run dep_statusdep_meta override_keyb dep_labelss r5 check_gatezStepRunner.check_gatesn !$,,/C((-G!!#& *J<<Y&,S17R<< :DAUJ#+<<0M#NL$(;(;(?(? (MQU(UR !%%-=&>?   Qzl!4 5104 ^hi^hYZ,QWWS\!_=CHHRST^hJi#3DIIj4I3JK  is.8E cddlm}||S)u이 단계가 적용 가능한지. False면 not_applicable. 기본 구현은 `app.core.applicability.resolve_applicability`를 호출. 특수 로직이 필요한 서브클래스(SceneSplitStep, SceneVerifyStep 등)는 override. r)resolve_applicability)app.core.applicabilityr)rrs r5check_applicabilityzStepRunner.check_applicabilitys A$T**r4z2^manifest_(\d{8}_\d{6})(?:_[a-zA-Z0-9_-]+)?\.json$z.force_clearedcP|j|jz jS)umforce_cleared marker 존재 여부 — load_checkpoint이 archive/manifest 모두 무효 처리하는 분기.)r_FORCE_CLEARED_MARKERexistsrs r5_is_force_clearedzStepRunner._is_force_cleareds  t999AACCr4c|jdz }|j}|jr} |jdj }|r:t j |}|r!tjd|jy|Stjd|j|r!tjd|jy|j}|y t j |jd} t||tjd |j|j|S#t$r+}tjd|j|Yd}~d}~wwxYw#t$r6}tjd |j|j|Yd}~yd}~wwxYw#t$r7}tjd |j|j|Yd}~|Sd}~wwxYw) u체크포인트 manifest.json 로드. Primary: manifest.json 직접 로드. Fallback (Fix 4 / M5): manifest.json이 빈 파일/없음/손상이면 가장 최근 archive(`manifest_TIMESTAMP[_runid].json`)로 자동 복원. archive가 살아있는 한 force 직후 backend kill 같은 사고에서도 dispatcher가 cp를 회복한다. F4-1 (Claude IMPORTANT): clear_checkpoint 직후 backend kill로 save 누락된 시나리오에선 archive(이전 completed)가 force 의도를 silent로 무효화할 수 있다. clear_checkpoint이 작성한 `.force_cleared` marker를 확인하여 archive 복구 + manifest.json 복원을 모두 차단 — resume이 stale로 인식하여 재실행. save_checkpoint(completed)가 정상 진행되면 marker 자동 제거. P2-1 (Codex): archive가 status='running' incremental snapshot이면 복구 후보에서 제외 — `_find_latest_archive`가 completed/partial archive만 반환. archive → manifest 자동 복구는 atomic_write_json으로 기록하므로 재시도 호출에서 fallback 비용이 1회만 발생. manifest.jsonraencodinguhStep %s: manifest restored but .force_cleared marker exists — treating as stale (force intent honored)Nz?Checkpoint manifest.json empty for %s. Trying archive fallback.z;Checkpoint load failed for %s: %s. Trying archive fallback.ugStep %s: .force_cleared marker present — skipping archive fallback (force intent honored, will rerun)z5Archive fallback parse failed for %s (archive=%s): %szKStep %s: manifest.json missing/empty/corrupt. Auto-restored from archive %sz5Archive fallback write failed for %s (archive=%s): %s)rrr read_textstriprdloadsrrrB Exception_find_latest_archiveerrorr:r)r manifest_path force_cleared text_datadataexcarchives r5load_checkpointzStepRunner.load_checkpoints( 6 ..0     ! )33W3EKKM ::i0D$G LL $KULL  NN5   ++- ? ::g///ABD  mT 2 NN]    ] QLL ,  LLG         LLG        sTAE E E$%E: 7F< E7 !E22E7: F9,F44F9< G<,G77G<c|jjsyg}|jjD]]}|js|jj |j }|s<|j|jd|f_|sy|jdd|D]y\}} tj|jd}t!|t"r|j%d nd}||d vr|cStj'd ||j {y#t$r+}tjd|j |Yd}~d}~wwxYw) ux최신 manifest_TIMESTAMP.json archive 파일 경로 반환 (없으면 None). 파일명 패턴: manifest_YYYYMMDD_HHMMSS[_].json TIMESTAMP 기준 내림차순으로 정렬 후, status='completed' 또는 'partial' 인 archive만 후보로 채택 (P2-1 Codex fix). P2-1: incremental save_checkpoint(status='running') archive를 복원하면 step_run.status='completed'로 남고 cp는 running snapshot이 되어 sync 누락 + downstream silent skip 사고 발생. final 상태 archive만 복구. 손상된 archive는 skip 후 다음 후보 시도. Nc |dS)Nrr3)xs r5r]z1StepRunner._find_latest_archive..sAaDr4T)keyreverseraru&Archive parse failed (skip): %s — %srrrr(z*Archive skipped (status=%s, not final): %s)rriterdiris_file_ARCHIVE_PATTERNmatchr:rgroupsortrdrrrrr isinstancer=rAdebug) rarchivespmtspathrjrrs r5rzStepRunner._find_latest_archivexs1||""$+-%%'A99;%%++AFF3AQ0 (  .$ 7!HB **T^^W^%EF /9$.GW[[*TF~+U!U LL ? LL2L4E4E F A NN:C @ @ AsCC D$C??DrcX|jdz }|j|d<|j|d<|j|d<|j |d<d|vr|j j dd|d<d|vrt|j|d<d |vr|j|j|d < |j|t|||j d}|dvr>|j|j z } |j#r|j%dy y y #t$rB}tjd |j|td |jd ||d }~wwxYw#t$r+}tj'd|j|Yd }~y d }~wwxYw)ug체크포인트 저장 (원자적). 기존 manifest.json은 복사로 보관 후 덮어쓰기. F4-1: status='completed' 또는 'partial' 저장 시 .force_cleared marker 제거 — force 명령이 정상 진행 완료된 신호. 'running' incremental save에서는 marker를 유지하여 backend kill 시 force 의도 보존. rrBrresolved_model updated_atschema_versionr config_hashproject_config_snapshotz!Checkpoint save failed for %s: %szCheckpoint save failed for : NrrT missing_okz0Failed to clear .force_cleared marker for %s: %s)rrBr_resolve_model_nowr|rArnrT_mask_sensitive_keysrrrrr RuntimeErrorrrunlinkr)rrrr final_statusmarkers r5save_checkpointzStepRunner.save_checkpoints 6 ,,YX!%!4!4!6 !YY[\ 4 '%)]]%6%67G%KD! "  $"5d6I6I"JD  %D 0.2.G.GH[H[.\D* + ]  " "= 1 mT 2xx) E E\\D$>$>>F ==?MMTM2# F ] LL!F$$F)c|jdz }|jr#|j||jd |jj dd|j|j z j dy#t$r+}tjd|j|Yd}~yd}~wwxYw)u`체크포인트 삭제 (기존 파일은 날짜시간 버전으로 보관 후 삭제). F4-1: clear는 force trigger의 일부 — 이후 backend kill로 save_checkpoint가 호출되지 않더라도 force 의도를 보존하기 위해 .force_cleared marker 작성. load_checkpoint이 이를 감지하면 archive/manifest 복구를 모두 차단하여 step을 stale 상태로 유지 → 다음 실행 시 force 동작 보장. marker 작성은 best-effort — 실패해도 clear 자체는 진행. 다음 정상 save에서 marker는 자동 제거된다. rTrparentsexist_okrz0Failed to write .force_cleared marker for %s: %sN) rrrrmkdirrtouchrrrrB)rrrs r5clear_checkpointzStepRunner.clear_checkpoints 6    !  " "= 1  D 1  LL  td  ; \\D66 6 = =t = L  NNB c   sAB B?!B::B?T)delete_checkpointstarget_step_idrc d|xs |j}t|}ddlm}t ||}|j }ddlm}|D]u} |jjtd|j|j| |dtjd} | j} | r4t!| dj#drt$j'd| ||s| |vrt$j)d| ||| t+|j,|jz d z d z |jz | z d z } | j/s |j1| | j3d  | j4j7d d | j4|j8z j;d x|r=|jj?t$j)dtA||||yy#t<$r"} t$j'd| | Yd} ~ d} ~ wwxYw)u downstream step을 stale 처리 + 체크포인트 삭제 (또는 stale 플래그만). Args: target_step_id: None이면 self.step_id 기준. editorial step이 타 step 체크포인트를 덮어쓴 경우 해당 step_id를 전달하여 그의 downstream을 무효화. delete_checkpoints: True면 체크포인트 파일까지 아카이브+삭제. False면 DB step_run만 stale (체크포인트는 덮어쓴 값 그대로 유지, editorial 재실행 용). r)get_consumes_downstreamrvaUPDATE step_run SET status = 'stale', updated_at = :now, run_id = CASE WHEN status = 'running' THEN :revoked ELSE run_id END WHERE project_id = :pid AND episode_id = :eid AND step_id = :sid AND status NOT IN ('pending', 'stale') RETURNING run_idz invalidated-)pideidsidrrevokeduinvalidate_downstream: 도는 중인 하류 %s 를 무효화했다 — 그 주행은 다음 안전 지점에서 멈춘다 (ref=%s)uPreserved stale checkpoint for %s (consumed by %s) — 파일 보존, DB stale. drift 방지를 위해 %s force 완료 후 %s도 재실행 권장rxryrTrrruCFailed to mark %s as invalidated (archive 복원 위험 잔존): %sNz:Invalidated %d downstream steps from %s (delete_cp=%s): %s)!rBrapp.core.step_catalogrsetrrrwrsexecuterrqrrr}r~fetchonerR startswithrrinforrrrrrrrrrcommitlen)rrrref downstreamrconsumesrrwrres_rowcp_pathrs r5invalidate_downstreamz StepRunner.invalidate_downstreams, 1#6  B3C89iik,C''//$##tsdjjl^'DFGC<<>DDG //?RSVX["(?KKuS#s ../$//A#$&0137??CEHIKZ[>>#**73NNdN3 ,,TD,I 5567F$=E\\(=Sc(,,x"89Y]EM\\R^E_#hll<&@"Aei +lH r4c|dk(rttjdS|j|j}|sttj ddS|d}|dk(r|j }|ttj d d S|j|}|rI|jjd d rttj|d S|j|S|j}|jrttjd S|jjd d r)ttjd|jd S|j dk(r,ttjd|jdddS|j dk(r,ttjd|jdddSttj d|jd S|dk(r|j#|S|dvr ttj d|ddSttj d|dS)uresume 판정자 — `(mode, step_run row, cp, verify_completion, project_config)` 를 관찰해 `ResumeDecision` 반환. 본 helper 는 자체 raise 안 함. `_safe_verify_completion` (B7) 이 AppError(step.verify_crashed) raise 시 helper 내부에서 catch 안 함 — caller (run() / step_execution_service) 가 fail-fast 처리. 분기 매핑 (current run() 동작 1:1 보존): - mode='force' → FORCE_EXPLICIT - first-run (no row) → RERUN_SELF (origin=None — cleanup 없음) - status='completed': - cp clean + verify pass → SKIP - cp None / cp mismatch / verify fail: - strict_resume=True + cp not None → BLOCK - 그 외 → RERUN_SELF (origin='artifact_missing') - status in {running, failed, partial, stale, pending}: - RERUN_SELF (origin='prior_state') - NOTE: running 자동 force 정책 변경은 후속 task (B4 STALE_RUNNING_RECOVERY). - 그 외 unknown status → RERUN_SELF (origin=None — current run() 의 fall-through 동작 보존) BLOCK 정책은 후속 task (B11) 에서. forcezuser-requested force)rIrJzfirst-run (no step_run row)NrIrJrKrrz0checkpoint missing but step_run.status=completedartifact_missing strict_resumeFzcp clean, verify passedzverify failed: contract_driftz#contract drift detected by verify: rinvariant_driftu2invariant drift detected by verify (1차 정책): running)failedrstalepending cancelledzstatus=u → force-like recovery prior_statezunknown status: )rHr"r/rrBr.r_check_cp_mismatchrTrAr1_evaluate_contract_drift_safe_verify_completion is_completer-missingrK_evaluate_running_state)rrr"rcp cp_mismatch verify_reports r5r z*StepRunner._evaluate_resume_decision_inners, 7?!#22-  %%dll3!#..4  (# [ %%'Bz%'22M-11"5K&&**?EB)+11*.44[AA!88:M((%',,4 ""&&>%'--,]-B-B,CD*##'77%'--=(00!457, ##'88%'--**7*?*?*C)DF- "#..()>)>(?@)  Y //9 9 K K!#.. (@A$ **%fZ0  r4r"c ddlm}|jd}|jd}tj|}t ||j |j|j\}}|tjur ttjd|||S|tjurttjd|d St!|jd |jd |jd f}|r ttjd|dd S|ttjd|d S t#j$t'|j)dd} | j0 | j)t2j4} |j6} t#j8t2j4| z j;} | | kr&ttjd| dd| d|d Sttjd| dd| d|||S#t*t,t.f$r%ttjd|d|d cYSwxYw)uHstatus='running' row 평가 — **죽음을 추측하지 않고 확인한다.** 2026-08-26 개편. 이전에는 `started_at` 경과 시간만으로 판정해서, 프로세스를 강제 종료하면 `step_running_timeout_seconds`(기본 3600초)가 지날 때까지 아무것도 못 했다 (새벽 실측 손실 40분). 지금은 `step_lock.judge_owner()` 가 소유자 신원으로 먼저 판정하고, 신원을 못 믿는 자리에서만 시간으로 떨어진다: - `OwnerVerdict.DEAD` → STALE_RUNNING_RECOVERY (바로 풀기) - `OwnerVerdict.ALIVE` → BLOCK (진짜로 일하는 중) - `OwnerVerdict.UNKNOWN` → 기존 경과 시간 경로 (신원 칸이 없는 구 행) ★`started_at` 이 없거나 깨진 것은 더 이상 무조건 BLOCK 이 아니다 — 신원이 죽음을 말하면 그것이 우선한다. 시간은 신원이 침묵할 때만 쓰는 마지막 그물이다. 본 helper 는 자체 raise 안 함 — caller (run()) 가 BLOCK / STALE 디스패치 책임. rrvrr)r lease_secondsallow_heartbeat_stealu소유자가 죽었다 — )rIrJrOrPu소유자가 살아있다 — running_healthyr'rrru*소유자 생사를 확정 못 했다 — uu. GET .../steps/locks 로 확인하고, 죽은 것이 맞으면 POST .../steps/locks/{step_id}/release 로 풀어라.z>running with started_at=None (manual investigation required); running_invalidZz+00:00z&running with started_at parse failed: z; )tzinfozrunning healthy (elapsed=z.0fz s < timeout=zs); zrunning stale (elapsed=z s >= timeout=)rrwrArfrom_rowrrstep_lock_lease_seconds!step_lock_heartbeat_steal_enabledrDEADrHr"r0ALIVEr1anyr fromisoformatrRr!r{ TypeErrorAttributeErrorrArutcstep_running_timeout_secondsr total_seconds) rr"rwstarted_at_raw run_id_rawownerverdictverdict_reason has_identityrtimeout_secondselapseds r5r7z"StepRunner._evaluate_running_state:s( -!l3\\(+ ""8,"-  "::"*"L"L #  l'' '!#::4^4DE$2 *   l(( (!#))77GH(   LL ) LL & LL (  !#))@@PQLL)   !!#))T%&()   !//N#++C:J    $#++8<<+@J"??<< - :IIK _ $!#))/}LHYY]%&()  66)'#mOCTTX!"$!/&  7I~6 !#))<^z.StepRunner._update_step_run.. s7YasGYsz5WHERE step_run.run_id = :rid AND step_run.status IN (raQ INSERT INTO step_run (id, project_id, episode_id, step_id, status, run_id, resolved_model, applicable_count, completed_count, failed_count, error_message, result_summary, started_at, completed_at, created_at, updated_at) VALUES (:id, :pid, :eid, :sid, :status, :rid, :model, :ac, :cc, :fc, :err, :rs, :sa, :ca, :now, :now) ON CONFLICT (project_id, episode_id, step_id) DO UPDATE SET status = :status, run_id = :rid, resolved_model = :model, applicable_count = :ac, completed_count = :cc, failed_count = :fc, error_message = :err, result_summary = :rs, updated_at = :now, started_at = COALESCE(:sa, step_run.started_at), completed_at = COALESCE(:ca, step_run.completed_at) z" RETURNING id )idrrrrridmodelacccfcerrrssacar)rrangerrrrsrrRr}r~rqrrrBrrziprr)rrr[r\rrr]r^r_rr completed_at _exp_keys owner_clausei_insqlrevresultrs r5_update_step_runzStepRunner._update_step_runs>iik"i/ST $(GGsT  "  ,1#o2F,GH,Gq3qc,GIH))7Y77CGuAN   N    djjl#DOODOO<<6$++((*2B/+8=$'d+9.$'tL ' !$I ?@ ?1q!t ?@ '  oo $GI<As E E)r\rrr]r^r_c |j|d||||||}|s+td|jd|jd|ddy ) uowner-aware update + False 반환 시 step.owner_lost AppError raise. V2 patch 추가 d (Codex IMPORTANT #4, plan v2.1.3 §2247): claim 후 transition 의 모든 path (success / partial / failed / exception handler / cleanup failure) 에서 owner check 실패 (False) 는 race lost 신호 — 자동 silent skip 금지. 모든 transition path 에서 surface 의무. TrZstep.owner_lostz owner check failed (run_id=uY) — 다른 worker 가 step_run row 를 갱신했거나 stale steal 당함. transition='u ' 미적용.rN)r|rrBr) rrr\rrr]r^r_updateds r5_update_step_run_strictz"StepRunner._update_step_run_strict.sv$'' ++-%')(  &||n$@ N##)(,8  r4rJcR|jdd|jd|dy)uNOT_APPLICABLE 처리 — claim 없이 DB step_run + cp 기록 (Block C, V2 patch I4). check_applicability=False 이거나 ResumeAction.NOT_APPLICABLE decision 시 호출. claim 안 했으므로 require_owner=False 로 단순 upsert. r(F)r[rrJN)r|r)rrJs r5_mark_not_applicablezStepRunner._mark_not_applicableUs, .eD (8FKLr4allow_stale_stealrOrPrrOrPcttj}|j}t \}}}t d} |j j| ||j|j|j|j|||||||d } | j} |j j| duS)uQatomic INSERT ON CONFLICT — race-free running claim (Block C C1). AC-C1, C6, C8, C9, C10, C11 (plan v2.1.3 / spec V5 §5.2): - first-run (row 없음) → INSERT 경로, RETURNING 한 row 로 success. - 기존 row + status != 'running' → DO UPDATE 경로 (failed/partial/stale/...). - STALE_RUNNING_RECOVERY (allow_stale_steal=True) → expected-match steal: step_run.started_at = :expected_started_at AND run_id = :expected_run_id. SQL cast 0 (V3 patch B1): timeout 판정은 _evaluate_running_state() 가 Python 에서 수행. invalid text started_at row 가 있어도 query 정상 작동. fetchone() is not None 판정 (V3 patch I2): rowcount driver 차이 회피. Returns: True (claim 성공) / False (다른 worker 이미 잡음 또는 expected mismatch). a INSERT INTO step_run ( id, project_id, episode_id, step_id, run_id, status, started_at, created_at, updated_at, owner_host, owner_pid, owner_boot_id, heartbeat_at, cancel_requested_at ) VALUES ( :new_step_run_id, :pid, :eid, :sid, :run_id, 'running', :now, :now, :now, :owner_host, :owner_pid, :owner_boot_id, CURRENT_TIMESTAMP, NULL ) ON CONFLICT (project_id, episode_id, step_id) DO UPDATE SET run_id = EXCLUDED.run_id, status = 'running', started_at = EXCLUDED.started_at, updated_at = EXCLUDED.updated_at, owner_host = EXCLUDED.owner_host, owner_pid = EXCLUDED.owner_pid, owner_boot_id = EXCLUDED.owner_boot_id, heartbeat_at = EXCLUDED.heartbeat_at, cancel_requested_at = NULL, recovery_count = step_run.recovery_count + CASE WHEN step_run.status = 'running' THEN 1 ELSE 0 END WHERE step_run.status != 'running' OR ( :allow_stale_steal IS TRUE AND step_run.status = 'running' AND step_run.started_at = :expected_started_at AND step_run.run_id = :expected_run_id ) RETURNING run_id ) new_step_run_idrrrrrrrrrrOrPN)rRr}r~rrrrsrrqrrrBrrr) rrrOrPrrrrrryr{rs r5_try_claim_runningzStepRunner._try_claim_running^s*djjl+iik/?/A, I} " " H.????<<kk$"*!2#6. '  oo $r4wherestrictrrc ddlm}ddlm}|} |j t d|j |j|jdj}|||j |j|} |j|%|r"td|jd|xsd dd y|j |j k7rszzl&/00AC    " "%||n$4S5L5L4MV/00AC     %||nHZ-@-@-B,C5/00AC   E     /<<.)!4_5S>==!$ NNV eS   MMO% $ MMOs+A+G IAH>)I>IIIrtotalr-c.|jd|||y)ufan-out 진행률 업데이트 (running 상태에서). claim 후 owner-aware (AC-C7). Block C review I4: owner_lost 시 silent skip 대신 strict 로 즉시 raise → fan-out 중단 (partial commit orphan 차단). caller 는 outer except 에서 surface. r,)rrr]N)r)rrrr-s r5update_progresszStepRunner.update_progress4s# $$ %" % r4c4ddlm}||jy)u;`grounding_mode` 오타를 **첫 지출 전에** 세운다 (fail-closed). ``resolve_grounding_mode`` 가 enum 밖 값에 ``AppError`` 를 던진다. 여기서 부르는 것은 「값을 쓰려고」가 아니라 **「틀린 값이면 아무것도 시작하지 않으려고」**다. r)rXN)rcrXrT)rrXs r5_preflight_grounding_modez$StepRunner._preflight_grounding_modeGs Ct223r4cy)uOmode 별 실행 가능성 preflight — run() 최선두(모든 mutating 단계 이전)에서 호출. subclass 가 특정 mode 를 거부해야 할 때 override 해 raise (예: 표적 씬 슬라이스+force 병용 금지 — 비표적 자산 무효화 차단, Codex 슬라이스 리뷰 BLOCKING-1). 기본=no-op.Nr3rrs r5 validate_modezStepRunner.validate_modeRsr4c"|j|j||j|js|j dddiS|j |}|j tjk(rdddS|j tjk(r|jdk(r|jd |jd }n|jd k(r|jd |jd }nc|jdk(r|jd|jd }n7|jdvr|jd|jd}n |j}td|dttj |j"|j$ |j'||tj(|j"|j$S#tj(|j"|j$wxYw)u단계 실행. mode: resume | force. Returns: {"status": "completed|skipped|not_applicable", "result": ...} Block C C2 (plan v2.1.3 / spec V5 §S2 + §S6): 4-phase 흐름 — (1) gate / applicability (non-mutating) (2) ResumeDecision 평가 (non-mutating, mutating side-effects only after claim) (3) atomic claim (RERUN_SELF / FORCE_EXPLICIT / STALE_RUNNING_RECOVERY 만) (4) origin 별 부수효과 (record_recovery / [RECOVERY] log) + _execute_* dispatch — _execute_rerun_self / _execute_force 가 _execute_and_finalize 로 finalize 까지 위임. zcheck_applicability=False)rJrr(skippedzalready completedrr)u% 체크포인트가 stale 입니다 (uC). strict_resume=True 이므로 force 모드로 재실행하세요.r*u contract drift detected — u.. force 재실행 또는 수동 진단 필요.r+u invariant drift detected — )r>r?z step is running (u}). 다른 worker 가 진행 중일 가능성 — auto-force 차단됨. 확인 후 mode='force' 로 명시 재실행하세요.zstep.resume_invalidrr)rrrrrr$rIr"r-r1rKrBrJrr LOCK_REGISTRYregisterrr_claim_and_run unregister)rrr#_msgs r5runzStepRunner.runXs0 &&( 4  '')  % %-H % I./ /11$7 ??l// /'3FG G ??l00 0/1||n% ():: $44||n$A(//ARSCC$55||n$B8??BSTCC$JJ||n$6x6GHMM  *   t}}dkk: A&&x6  $ $T]]DKK @M $ $T]]DKK @s &G"",Hr#c |jtjk(}|j||r |jnd|r |j nd}|s5t d|jd|jjd|dd|rAtjd |j|j|j |j|jtjk(r|jd k(r|j}|Wd d lm}|j#d } |||j$}tjd|j|j*||j-|j*} tjd|j|j*| |j/d}n |jtjk(r^|jdk(rOtjd|j|j0|j2|j4|j*d}n|jtjk(ri|jdk(rZ|j-|j*} tjd|j| |j*|j/d}n|jtj6k(rd}|dk(r=|jtjk(r|j9S|j;S|j9S#t&$r} dt)| i}Yd} ~ d} ~ wwxYw)ueclaim 이후의 실행 — 등록부 등록이 끝난 상태에서만 불린다. `run()` 에서 떼어낸 이유는 하나다: 락 등록부의 해제를 `finally` 로 보장하려면 claim 이후 전체가 한 블록이어야 하는데, 그러면 100줄 넘는 본문이 통째로 한 칸 들어가 diff 가 안 읽힌다. Nrzstep.already_runninguX 이 이미 다른 worker 에서 실행 중 (또는 stale read 후 갱신됨). decision=z, is_stale_steal=.rrzj[STALE_RUNNING] step=%s atomic steal succeeded (expected_started_at=%s, expected_run_id=%s, new_run_id=%s)r(r)_diff_project_configr _diff_errorz3Step %s stale detected: %s. Project config diff: %sz%[RECOVERY] step=%s reason=%s cycle=%dr&r1uY[RECOVERY] step=%s prior_status=%s prior_run=%s prior_updated=%s reason=%s → force-liker*z8[RECOVERY] step=%s allowlist contract_drift cycle=%d: %s)rIr"r0rrOrPrrBvaluerrrr.rKrrrrArTrrRrJ_record_recovery_check_recovery_exhaustedrLrMrNr/_execute_rerun_self_execute_force) rr#ris_stale_stealclaim_okr8r cp_snapshot config_diffdiff_exc new_counts r5rzStepRunner._claim_and_runs#//\-P-PP**,@N < ? A"6{DDWDW"XKILL(//; --hoo>I NN7 hooy   * * ,D __ 7 7 7HOO}<\ NNk h33X5J5JHLeLegogvgv D __ 7 7 7HOOO_<_--hoo>I NNJ i   * * ,D __ ; ; ;D 7?,"9"99//11&&( (''))U!A#0#h-"@KAsL** M 3 MM c&|jdS)uauto-recovery 경로 — 자기 step 만 rerun (Block B B12, AC-B6). force 와의 차이: - cleanup_artifacts() 호출 X - invalidate_downstream() 호출 X - clear_checkpoint() 호출 X - downstream cp 보존 (auto-recovery 가 downstream 영향 X) finalize 는 _execute_and_finalize() 공통 helper. _execute(mode='resume') 호출 — force-like 격상 X. r execute_mode)_execute_and_finalizers r5rzStepRunner._execute_rerun_self8s))x)@@r4ct |j}|js |jrAt j d|j|j|j|j|j|j|jd S#t$r} |jdd|nR#t$rF}|jdk7rt j d|j|j|Yd}~nd}~wwxYwt jd|j|d}~wwxYw) uR사용자 명시 force — cleanup + invalidate_downstream cascade (Block B B12, AC-B6). AC-B6 의 대척 경로 — force 는 의도적으로 downstream invalidate. cleanup_ artifacts 예외 시 status='failed' 영속 + raise (silent fallback 금지). finalize 는 _execute_and_finalize() 공통 helper. r-zcleanup_artifacts crashed: r^r~z2Step %s force-cleanup owner_lost: %s (original=%s)Nz%Step %s cleanup_artifacts crashed: %sz-[CLEANUP] step=%s rows=%d files=%d targets=%sr&r)cleanup_artifactsrrrrrrrBrrdeleted_db_rows deleted_filestargetsr rr)rcleanup_reportr owner_excs r5rzStepRunner._execute_forceFs% !335N,  ) )^-I-I NN? ..,,&&   ""$ ))w)??A  ,,$?u"E- >>%66HLL)"3"3S  LL7 c  ) s;B D7'B>=D2> D ._paid_call_gates  'GPT Ur4rUN) app.modules.llm.llm_clientrrrrrBrrr>app.core.image_call_budgetrrE_execute_and_finalize_inner)rrrrrs` r5rz StepRunner._execute_and_finalizeqs$ @ $$Y/ 3 LL$++t':':'<  1134" C Vt $&00% $ $s BB'cddlm}d} |j|}||_|j dd}|j dd}|j dd}|dk(rd n|dkDrd nd }|d k(rJ |j } | js-tjd|j| j d }|j||||t#j$|j'D cic]\} } | dk7s t)| t*r| | !c} } dt,dd|j/d|i||d k(r|j1|j2j dxsg}|j2j dd}|dvr@|r>|r|D]}|j5|dn!tj7d |j|tj9d!|j||||||d"|dS#t $r} tjd |jt| d d| j |jd |||dt| d dd| jd}#t $rG} | jdk7rtjd|j| jYd} ~ d}d} ~ wwxYwd} ~ wwxYwcc} } w#t:$rr}ddl}t)|t rt|d d#d$k(rtjd%|j|j |jd&|j'#t $rE} | jdk7rtjd(|j| jYd} ~ d} ~ wwxYw|s{ |jd t-||j>)nR#t $rF} | jdk7rtjd*|j| j|Yd} ~ nd} ~ wwxYwtjd+|j||jAd}~wwxYw#|dwxYw),uG`_execute_and_finalize` 의 본문 — 옮기기만 했다(내용 변경 0). 스텝 경계에 Opik trace 를 겹치려면 본문을 with 로 감싸야 하는데, 그러면 100줄 넘는 블록이 통째로 한 칸 들어가 diff 가 안 읽힌다. 그래서 본문을 메서드로 떼어 내고 바깥에서 감쌌다. ★`set_opik_context` local import 는 함께 옮긴다 — finally 절이 그것을 쓰는데, 바깥 함수의 지역 이름은 여기서 안 보인다(호출 시점까지 안 드러나는 결함이다). rrF)rrrrr]rrr-u4[VERIFY-EXIT] step=%s exit verify crashed: %s — %sr?zexit verify crashed: r)rrr]r^r~z3[VERIFY-EXIT] step=%s owner_lost on failed-mark: %sNTu,[VERIFY-EXIT] step=%s failed → partial: %sr)r_r`rg)rrr]r_rmodifies_checkpointsinvalidate_downstream_on_edit)rr)rrz>Step %s: editorial cascade skipped (policy=1-pass, targets=%s)z'Step %s %s (completed=%d/%d, failed=%d))rr{rru[CANCELLED] step=%s — %sr0ru(Step %s cancel 기록 중 owner_lost: %s)r^r\z3Step %s exception path owner_lost: %s (original=%s)z,Step %s _execute_and_finalize crashed: %s %s)!rr_execute_last_execute_resultrAr4rrrrBgetattrrrrrr5r6rdreitemsrbytesrRr_reset_recovery_counterr|r rrr traceback_TERMINAL_ROLLBACK_FROM format_exc)rrrfailed_recordedr{rrr-r exit_report verify_excrrerzmods cascade_on target_sidrrs r5rz&StepRunner._execute_and_finalize_innersh @ [ #]] ]5F(.D % #4a8IJJ115EZZ2F &{ #,q=ih  {*"&">">"@K<#..NNF k&9&9$-L  ( ( )!&##zz&,llnandaV JWXZ_L`QTna!& 4  )   (L!CF!C D{*,,.==$$%;<BD**+JERJ77D&* 22+5/43'+ LLX d KK9 lIuf +f=| T "O LLN  FC8"** 44$,5-2)/"7#*:vs#C"DE*J\J\I]!_ 5 "'+O$$>>->>!Q LL)*;*;'+O)Vb@:  3)C,0@@;T\\3;;W 00#3;;1  ~~)::NNB i&7&7#00 C(,(D(D1  ~~)::NNM i&7&7 LL? c9#7#7#9  u: x T "sA$K/G>?A*K) K7KK C(K> K 7K?1I30K3 K<;J>7K>KKK  K QAQ .M  Q  N;NQ NQ  'OQ  P= MAX_RECOVERY_ATTEMPTS면 step.recovery_exhausted raise. Audit A4 (DRY): 기존 dual gate(resume 분기 record 전 + force 분기 진입 직전)를 한 곳으로 통합. 호출 site는 `_record_recovery` **직후** — post-increment된 새 카운트로 즉시 검사하여 force 분기 진입 자체를 차단한다. message에는 module 상수 MAX_RECOVERY_ATTEMPTS를 명시 — silent recovery로 묻히지 않게 사용자에게 한계값을 노출하고, 회귀 테스트의 "3" 포함 검사도 보존한다(누적 카운트와 한계가 모두 표시됨). zstep.recovery_exhaustedu auto-recovery 한계(u회) 도달 — 누적 u회 실패. 마지막 사유: u. 수동 진단 필요.rrN)_get_recovery_countr rrB_get_last_recovery_reason)rcounts r5rz$StepRunner._check_recovery_exhaustedysn((* ) ).||n$:;P:QR#W$B4CaCaCcBde,,   *r4c H|j}|jjtd|dd|j|j |j ||jd}|jj|j|d|jS)u)recovery_count++ + last_recovery_reason 적재. 새 카운터값 반환. 호출 site: entry verify 실패 시. mode='force' 격상 직전. ★한 줄도 안 바뀌면 **내 토큰이 이미 버려진 것**이다 (2026-08-26 Codex 재리뷰 BLOCK-4). 종전에는 `run_id` 조건만 걸고 결과를 안 봐서, 토큰이 버려진 뒤에도 조용히 0줄로 끝나고 바로 아래 `_get_recovery_count` 가 **새 주인의 줄**을 읽었다. 남의 카운터로 내 한계를 판단한 셈이다. a4 UPDATE step_run SET recovery_count = recovery_count + 1, last_recovery_reason = :reason, updated_at = :now WHERE project_id = :pid AND episode_id = :eid AND step_id = :sid AND run_id = :rid AND status = 'running' Nrg)rJrrrrriurecovery_count 증가) rrsrrrqrrrBrr_require_owned_rowr)rrJrr s r5rzStepRunner._record_recoverysiikggood$   toodll3kk# $  %<=''))r4r{whatc ~t|dd}|dk(r+td|jd|d|jdd y) u방금 UPDATE 가 **내 줄**을 건드렸는지 확인한다. 0줄이면 내 토큰이 버림됐다는 뜻 — 조용히 넘어가면 그 뒤 판단이 전부 남의 줄을 근거로 이뤄진다. 여기서 멈춘다. rowcountNrr~ u 실패 (run_id=uw) — 이 주행의 토큰이 버림됐다. 다른 주행이 이 스텝을 가져갔거나 정지·풀기로 놓았다.rr)rrrBr)rr{rrs r5rzStepRunner._require_owned_rowsX 6:t4 q=&||nAdV+;DKK=I33   r4c "|j}|jjtd|j|j |j ||jd}|jj|j|dy)ustatus='completed' 정상 진행 시 카운터 reset (다음 sweep 깨끗한 상태). ★부르는 자리가 `_update_step_run_strict(final_status)` **뒤**이고 `final_status == "completed"` 일 때뿐이다. 그러니 이 시점의 DB status 는 'completed' 여야 한다 — 아니면 그 사이에 누가 끼어든 것이다 (2026-08-26 Codex 2차 재리뷰). z UPDATE step_run SET recovery_count = 0, last_recovery_reason = NULL, updated_at = :now WHERE project_id = :pid AND episode_id = :eid AND step_id = :sid AND run_id = :rid AND status = 'completed' )rrrrriurecovery_count 초기화N) rrsrrrqrrrBrrr)rrr s r5rz"StepRunner._reset_recovery_counterssiikggood$  oodooll3t{{D E  %?@r4c|jjtd|j|j|j |j dj}|r|dSdS)NzxSELECT recovery_count FROM step_run WHERE project_id = :pid AND episode_id = :eid AND step_id = :sid AND run_id = :ridrrrrirrsrrrqrrrBrrrrs r5rzStepRunner._get_recovery_countsbggood " ??4??<<  5 6 7?hj s1v#!#r4c|jjtd|j|j|j |j dj}|r |dr|dSdS)Nz~SELECT last_recovery_reason FROM step_run WHERE project_id = :pid AND episode_id = :eid AND step_id = :sid AND run_id = :ridrru(없음)rrs r5rz$StepRunner._get_last_recovery_reasonsfggood " ??4??<<  5 6 7?hj #a&A9j9r4cd}|siSi}|jD]M\}tfd|Drd|< t|trtj ||<I||<O|S)uproject_config 저장 전 민감 키 마스킹. api_key/password/secret/token/credential 패턴. nested dict는 재귀. None → 빈 dict. D2 fix — save_checkpoint이 project_config_snapshot 기록 시 사용. )api_keypasswordsecrettoken credentialc3TK|]}|tjv!ywN)rRlower)rdsres r5rfz2StepRunner._mask_sensitive_keys..s!: 11A & s%(z***)rrGrr=rpr)config SENSITIVEmaskedrzres @r5rzStepRunner._mask_sensitive_keyssqM ILLNDAq: ::!q At$&;;A>q q # r4c ddlm} |jS#t$rz}t |dddk(rt j d|j|jt |dd|dd |jgd d t |ddid cYd}~Sd}~wt$rO}t jd|j|dtddt|jd||d}~wwxYw)uverify_completion 실행 + 예외 분류 (Block B B7, plan v2.1.3 / spec V5 §4.3). - AppError(code='step.verify_crashed') → propagate (B8 verify_completion 이 card recompute 등에서 미리 격상한 케이스 — 이중 wrap 금지). - 그 외 AppError (loader contract / step.contract_violation 등) → CompletionReport(origin='contract_drift', is_complete=False). caller (run() / ResumeDecision helper) 가 BLOCK 처리 (B11 후속). - 그 외 Exception (KeyError / ValueError / AttributeError 등) → AppError(step.verify_crashed) raise (자동 force 금지, fail-fast). silent recovery 사고 패턴 차단. rrrNzstep.verify_crashedz/verify_completion AppError for %s: %s (code=%s)rFz contract: r6app_error_coder*)r5r6rr;rKz$verify_completion crashed for %s: %sT)exc_infozverify_completion crashed: r)rr) rrrrrrrrBrrrr[r))rrrs r5r4z"StepRunner._safe_verify_completions ? ))+ + sFD)-BB NNA ckk73+D $!%ckk]34"*GC,FG'    LL6 cTX  *5d3i6H6H5IC5Q   s( C1A/BC1 C1"A C,,C1r8c4|jjdd}|jd}|jd}| ||k7rd|d|S|It|dd}t|r |}d}nt |j }d }||k7r d |d |d |Sy) u|cp의 schema_version + config_hash와 현재 manifest/project_config 비교. Returns: mismatch reason str (None이면 일치). run() resume 분기의 P0-3 mismatch 검증을 헬퍼로 이관. legacy 체크포인트(cp_schema/cp_hash 누락)는 None 반환 — 호환 보장. config_hash 비교 (Codex iter root cause): save_checkpoint (line 349-350) 는 step 이 _execute() 에서 명시 반환한 'config_hash' 가 있으면 그것을 보존하고, 없으면 compute_config_hash( project_config) 로 fallback. 따라서 mismatch check 도 step 의 자체 hash method (`_config_hash()`) 가 있으면 그것으로 계산해야 일관. 이전 결함: _execute 가 SHA256(prompt_version+model+...) hash 저장 → check 는 MD5(project_config) hash 비교 → 영구 false-positive mismatch. rrrNu)schema_version mismatch: 체크포인트=u , 현재= _config_hashz step-localrTzconfig_hash mismatch (z): cp=z , current=)r|rArcallablernrT)rr8current_schema cp_schemacp_hash local_hash_fn current_hash hash_kinds r5r2zStepRunner._check_cp_mismatch"s**+;Q?FF+, &&'  Y.%@>ykSaRbc c  $D.$?M & - ( 243F3FG , ,&,YK8!*\N< r4c4td|jd)u서브클래스에서 구현. 실제 LLM 호출 수행. Returns: { "completed_count": N, "applicable_count": N, "failed_count": N, "data": {...}, # 단계별 결과 데이터 } zStep z must implement _execute())NotImplementedErrorrBrs r5rzStepRunner._executePs"E$,,7Q"RSSr4cHddlm}||j|jS)u&현재 단계의 모델 별칭 반환.r)r)rrrBrT)rrs r5rzStepRunner._resolve_model^s=dllD,?,?@@r4 extra_tagsextra_metadatac|j|jd}|j}|jdr?|jddd|jddd|j|d<|d|d<|jg}|jdr|d|d <|j |d|jdr|d|d <|j |d|r|j |||d <|r"|jD]\}}||vs |||< d d lm }t|ddrd dl m } m } |jdd|jdd|jd d|jd d| |jdd|jdd|jxsd|d<|jdr|d|d<|jdr|d|d<|jdr|d|d<| |j} |xsgD]} d| } | | vs | j | | |d <|S#t$r!}t j#d|Yd}~|Sd}~wwxYw)uOpik metadata 구성 — thread 그룹핑 + 프로젝트/에피소드 정보. extra_tags: Opik 태그에 추가할 낮은 카디널리티 문자열만 사용 (예: "retry", "gpt_fallback"). 동적 ID(scene_index, shot_index 등)는 태그가 아니라 extra_metadata에 넣어야 Opik 인덱스 카디널리티 폭발을 방지한다. extra_metadata: 메타데이터 dict에 merge. 필터링은 metadata 기반으로 가능. )rqrrrun_tag project_namerz > episode_title trace_name session_idproject_name_tagepisode_title_tagr8rrvopik_trace_v2_enabledF)build_axis_tagsepisode_thread_idN)rrrrr9pipeline_project_name)stepzstatus:u-build_opik_metadata v2 실패 (non-fatal): %s)rqrrrtrArBrextendrrrwrr<r!r"r@rrr)rrrrDctxr8rerzrwr!r"axisttagrs r5r>zStepRunner.build_opik_metadatacs"////  779 $'GGNB$?#@CGGO]_D`Caadeieqeqdr!sD !$YD  ~ 77> "'*>':D# $ KKN+ , 77? #(+O(#4"%[!77>*474GD0177?+,/,@D)779%&))nDO'DLL9$**A#A3-C$ C(+ $V   O LLH# N N  OsDI+I I/I**I/cdtjtjj Sr)rrrrK isoformatr3r4r5rzStepRunner._nows||HLL)3355r4)NNr)rrrUNr)rUr)r)r)r)rUr)rUr)Dr)r*r+r,rR OrmSessionr r rrboolrrecompilerrrrrr staticmethodrrrr r rpropertyrrHr$r r7r3rr intr|rrrrrrrrrrrrrrrrrrrrrr=rr4r2rrr r>rr3r4r5rprpsG*.'+       !  tn <.`+T+"rzz=-D4DY$Yv)htn)VAA$3D3T3j8_hl_HSM_ae_qu_F  S  Xd38n-E  D@@. c  G CG ~G R| S#X| >| |   DB $+7 ! PP P sCx P  PPPPP Pl,8 ! %%sCx %  %  %%%% %NM3MM#(-1)- R R&c] R "# R  Rh/1@@$@4@D  S # d & 4H#H$H bAbA4S>bAHx*~x*Sx*T#s(^x*x AT#s(^ A)@S#X)@Vr@s   %!'BB0I4$   8 $ s&4&( $***H"2 2)C)C3)CXN 6N 6r4