-ǚj*UdZddlmZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZddlmZddlmZddlmZdd lmZmZmZdd lmZdd lmZmZmZdd l m!Z!ejDe#Z$d Z%de&d< d,dZ'd-dZ(d.dZ) d/dZ* d/dZ+ d0dZ,ddd d1dZ-d2dZ. d3 d4dZ/ d5dZ0 d6dZ1 d7dZ2 d3 d8dZ3dZ4 d9d Z5 d:d!Z6 d;d"Z7dd#d#dd$ d d?d)Z< d@d*Z= d3 dAd+Z>y)BuqStepRunner 기반 분석 dispatch 서비스. Phase 4.1 (architecture-refactor-final/02-final-roadmap.md §Phase 4). 기존 `AnalysisService.run_analysis/reanalyze_scenes` 경로와 `steps.run_all_steps`의 `_run_all_bg` 내부 로직을 단일 dispatch 진입점으로 통합. 공식 경로: Frontend / API / 내부 호출 전부 StepRunner (→ StepCatalog) 경유. ) annotationsN)datetimetimezone)AnyDictListOptionalTuple)Session SessionLocal)AppError)ImageCallBudgetinstall_budgetuninstall_budget)submit_background_job) STEP_CATALOGget_active_entriesget_all_downstream_recursive)orchestrate_full_sync)analysisimageall reanalyzezTuple[str, ...]RUN_ALL_CATEGORY_TOKENSc 4ddlm}ddlm}|j |j |j |k(j}|j |j |j |k(|j|k(j}|r |jn|dd}|r |jn|dd}tjtjjd} |d|d| dt!t#j$dd} ||| dS) u(Opik thread 그룹핑용 context 생성.r)ProjectRegistryEpisodeNz %m%d-%H%M%S_) project_name episode_titlerun_tag)app.models.catalograpp.models.projectrqueryfilteridfirst project_idnametitlernowrutcstrftimestruuiduuid4) dbr+ episode_idrrprojectepisoder"r#tsr$s \/Users/manta/Documents/Projects/TheRoad-I1/backend/app/services/analysis_dispatch_service.pybuild_opik_contextr:0s3* !((););z)IJPPR    j('*<*< *J K  $+7<< 2AL%,GMM*Ra.M hll # , ,] ;Ba at1S5Fr5J4KLG$& cFddlm}|j|j|j|k(j }|r |j siS tj|j S#tj$rtjd|icYSwxYw)uGProjectSettings.llm_config_json 로드 (없거나 손상 시 빈 dict).r)ProjectSettingsuEMalformed llm_config_json for project=%s — falling back to defaults) r&r=r'r(r+r*llm_config_jsonjsonloadsJSONDecodeErrorloggerwarning)r4r+r=pss r9load_project_llm_configrEJs2 ! **j8 9  R'' zz",,--    S   sA22+B B c"ddlm}|||S)utext/PDF/checkpoint 중 하나라도 있으면 True (단일 source 위임). PDF-only 업로드 후 text 추출 짧은 경우에도 True 반환되어 dispatcher 가 planning_doc_analysis step 을 cascade 에 포함시킴 (review IMPORTANT 통일). r)project_has_planning_doc)r4)*app.services.planning_doc_analysis_servicerG)r4r+rGs r9_project_has_planning_docrI_s T #J2 66r;cxddlm}|j|d|||dj}|sy|ddk(S)ustep_run.status == 'completed' 여부 판정. Fix 3.3 prerequisite 검증용. partial은 아직 완료 미달로 처리하여 사용자에게 명확한 에러를 노출 — silent transitive invalidate 보다 안전한 정책. r)textz\SELECT status FROM step_run WHERE project_id = :pid AND episode_id = :eid AND step_id = :sid)pideidsidF completed) sqlalchemyrKexecutefetchone)r4r+r5step_id _sql_textrows r9_is_step_completedrVjsR- ** O :g>   hj   q6[  r;cFt||||ryddlm}||||dk(S)uprerequisite 검증용: step이 완료되었거나 applicability로 skip 가능한지. Codex P1-1: image preflight applicability 무시 사고 fix. background_mode=='off' (default) 환경에서 background_classify / floor_plan_prompt / background_prompt 등은 applicability='if_background_mode' → 정적 평가 시 not_applicable. StepRunner는 자동 skip 처리. prerequisite 검증이 이를 무시하고 _is_step_completed=False로만 판정하면 category='image' force가 dispatch.deps_incomplete로 차단되는데, 실제 실행 시에는 StepRunner가 이를 skip하고 downstream gate를 통과시키므로 차단은 잘못. 판정 로직: 1) step_run.status='completed' → True (이미 완료) 2) applicability 정적 평가 결과 not_applicable → True (StepRunner skip 가능) 3) 그 외 → False (prerequisite 미충족 — 사용자에게 명확한 에러 안내) Tr)evaluate_step_applicabilitynot_applicable)rVapp.core.applicabilityrX)r4r+r5rSrXs r9_is_step_satisfiedr[s-*"j*g>B &w J GK[ [[r;c 6|dk7ryg}|D]N}t|D]>}||vr|j|}|s|j|k7s,|j||f@P|r6t |D chc]\} }| c}} } t dd|d| d|dd ycc}} w) uiFix D (cascade fix 2026-05-05): mode=force 시 invalidate_downstream 이 cross-category step 무효화할 risk 를 시작 시점에 거절. StepRunner.run() 의 force 동작이 invalidate_downstream(delete_cp=True) 호출 → transitive downstream manifest 모두 delete. batch 안에 없는 cross-category step 도 delete 됨 → batch 진행 중 mid-cascade missing 발생 (e.g. floor_plan_render(image) force → background_prompt(analysis) manifest delete → background_render 시점 fail; scene_detail(analysis) force → scene_image_pipeline (image) manifest delete → 후속 image batch 가 stale). 검증: 각 batch step 의 transitive downstream 중 batch 외 active step 의 category 가 현재 category 와 다르면 risky. 시작 시점 fail-fast + 사용자에게 `category=all &mode=force` 또는 `category=&mode=resume` 안내. Args: direct: batch 에 포함된 step_id list. direct_set: direct 의 set (transitive downstream 검사 시 batch 내 step skip). active_by_id: step_id → entry. caller 에서 한 번 build 후 재사용. mode: "resume" 또는 "force". "resume" 면 검증 skip. category: 현재 batch category ("analysis" / "image"). non-matching downstream 만 risky. Raises: AppError(dispatch.force_cascade_cross_category) — risky 발견 시. forceNz%dispatch.force_cascade_cross_categoryz category=u6 mode=force 가 cross-category step 무효화 위험: u-. `category=all&mode=force` 또는 `category=u&mode=resume` 사용 권장.codemessage status_code)rgetcategoryappendsortedr) direct direct_set active_by_idmoderdcross_downstreamrNdsidds_entryr! cross_stepss r9_check_force_cascade_riskros> w.005Dz!#''-H  H, ''d 462BC2Bwq$d2BCD 8H<(%%0M2%J&BD  Cs( B resumer5rjc@|dvrtdd|d|dvrtdd|d dt||}g}tD]K}|d k7r|j|k7r|j}|d vr)|d k(r|s1|j |j Md dlm|dk7r|dk(r|tD cic]} | j | } } t|} g} |D]p} | xsi}|jdgD]M}|| vr| j|}|s|jdk7s,t||||r;| j | |fOr| r0t| Dchc]\}}| c}}}tdd|ddt|| | |dt|fdS|tD cic]} | j | }} t|}g}|D]`} | xsi}|jdgD]=}||vr|j|}|st||||r+|j | |f?b|r0t|Dchc]\}}| c}}}tdd|dd|dk(r|t||dt|fd}|Scc} wcc}}wcc} wcc}}w)u카테고리(analysis/image/all)에 해당하는 실행 가능 step_id 목록. applicability(on_demand/disabled/if_planning_doc)를 정적 필터만 수행. 이외 applicability는 StepRunner 런타임(resolve_applicability)에서 처리. Fix 3.3 (M4 해소): category="image" 동작 변경. 이전: image step의 transitive deps(analysis 포함) 자동 포함 — 사용자가 의도한 "image만 force" 가 실제로 거의 모든 step force로 폭발 (오늘 13:13 사고 trigger). 현재: image step만 직접 반환. analysis dep이 미완료/stale이면 prerequisite 검증으로 거부 (AppError code="dispatch.deps_incomplete"). 사용자가 다음 행동(category=all 또는 해당 analysis step 먼저 실행)을 명시적으로 선택. silent miss는 prerequisite 에러로 대체. prerequisite 검증은 episode_id가 제공된 경우에만 적용 (preview/list 호출은 episode 없음). Fix D (cascade fix 2026-05-05): `mode="force"` 시 force-invalidate 가 cross-category downstream step 을 무효화할 risk 를 시작 시점에 거절. StepRunner.run() 의 force 동작이 invalidate_downstream(delete_cp=True) 를 호출 — 만약 image step 의 transitive downstream 이 active analysis step 을 포함하면 batch 진행 중 mid-cascade missing 발생 (e.g. floor_plan_render force → background_prompt manifest delete → background_render 시점 fail). )rrrzdispatch.invalid_categoryzUnknown category: r^r_)rpr]zdispatch.invalid_modez&mode must be 'resume' or 'force' (got )r on_demanddisabledif_planning_docrget_manifest_dictrr depends_onzdispatch.deps_incompleteuNanalysis step 실행 전 cross-category prerequisite step 미완료입니다: u. `category=all` 사용 권장.c<|xsijddSNordercrcsrys r9z+select_steps_for_category..4s->q-A-GR,L,LWVX,Yr;)keyuIimage step 실행 전 다음 prerequisite step들이 미완료입니다: uE. `category=all` 사용 또는 해당 step을 먼저 실행하세요.r]c<|xsijddSr|rrs r9rz+select_steps_for_category..cs,=a,@,FB+K+KGUW+Xr;)rrIrrd applicabilityrerSapp.core.step_manifestrysetrcr[rfro)r4r+rdr5rj has_planningrgentryappleactive_by_id_a direct_set_a cross_depsrNmetadep dep_entryr!dmissingrirhincomplete_depsorderedrys @r9select_steps_for_categoryrs7833,( 3   &&( ? E E G ")){*BI -et 4B  IIK+2  ;WE  KKM     s<A-A88 CCB)(C) B52C4B55CCcddlm} |j|j|j|k(j }|r9|j dk(r)d|_d|xsddd|_|jyyy#t$rF}tjd | |jn#t$rYnwxYwYd}~yYd}~yd}~wwxYw) u정지로 멈췄을 때 `analyzing` 잠금을 푼다 — **`error` 로는 안 적는다.** `analyzing` 은 「지금 돌고 있다」는 뜻이라, 착수 검사가 그것을 보고 재실행을 409로 막는다. 세워 놓고 다시 못 돌리게 되는 것이다. ★그렇다고 `error` 도 아니다. 운영자가 멈춘 것이지 깨진 것이 아니다. 상태는 `stopped` 로 적고, 사유는 `analysis_error` 칸에 남긴다 (그 칸이 「무슨 일이 있었나」를 담는 유일한 자리다). rrrstoppedu주행 정지: (사유 없음)Nru0정지 뒤 에피소드 상태 해제 실패: %sr)r4r5reasonrrexcs r9!_release_episode_status_on_cancelrs+  XXg  % %gjjJ&> ? E E G ")){*!BI"1&2M= 1``; otherwise :class:`AppError` (``step.image_generation_not_approved`` / ``step.image_call_cap_required``) is raised before any worker is submitted. )rrNrsettings background_render_reference_modelegacyshot_aware_plan)capz"step.image_generation_not_approvedzKW20 shot-aware image phase requires explicit approve_image_generation=true.r^r_zstep.image_call_cap_requiredz8W20 shot-aware image phase requires image_call_cap >= 1.)app.core.configrgetattrmaxintrr)rdimage_call_capapprove_image_generation _settings render_modecap_ints r9evaluate_image_call_budget_gaters0''5)%GRK''  !a^,-7++ $51   ^!4q!8/J    s>2 33r;c " | t|t}d} ddlm} d} d} t } |D]} ddlm}||||}|jr>tjd| |jd} d|jd }n` | | xsi}|jd gDcgc] }|| vs| }}|r)tjd | || j| |jd dr t|||t#| |||||}|j%|}|jdd}tj'd| ||jd dr t|||| |dk(r tjd| d} d| d}nR|dk(rJ|jdddur tjd| d} d| d}ntjd| | r)tjd&t/| t1| | rNtjd'|xsd(t3|||dd)|xsd*d+|j5| t7SS| r1 t|||dd.d/d+|j5| t7SSt9|||xsd0dd|xsd0d+|j5| t7SScc}w#t$r=}tjd | ||j!d} d| d|}Yd}~,d}~wwxYw#t$r2}tjd| ||j!Yd}~d}~wwxYw#t($r}|j*dk(r6tjd | |j,d} |j,}Yd}~|j*d!k(r8tjd"| |j,| j| Yd}~tjd#| |j,d} d| d|j,}Yd}~Cd}~wt$r-}tjd$| |d} d| d%|}Yd}~wd}~wwxYw#t$rf}tjd,||j!t9||d-|ddd-|d+cYd}~|j5| t7SSd}~wwxYw#t$r}tjd1| |j!n#t$rYnwxYwt9||t;|ddt;|d+cYd}~|j5| t7SSd}~wwxYw#|j5| t7wwxYw)2ustep_ids 순차 실행 — background job 내부에서 호출되는 실제 워커. 각 step 완료 후 sync projection(체크포인트→DB). 실패/partial 처리 포함. 실패 시 episode.status를 'analyzing' → 'error'로 복구. Returns: ``{"ok": bool, "outcome": "completed|cancelled|failed", "reason": str}`` ★★★2026-09-04 — 종전에는 **아무것도 안 돌려줬다**(`None`). 실패를 `all_ok=False` 로 접고 episode.status 만 고친 뒤 조용히 끝났다. 그래서 프로젝트 대기열이 「앞 화가 실패했나」를 알 길이 없어 **다음 화를 그대로 시작했다** (Codex BLOCK 2026-09-04). 배경 작업 경로는 이 값을 안 쓰므로 계약은 뒤로 호환된다. W20E5 — ``budget`` (optional) is installed on the worker thread for the duration of the run and cleared in ``finally`` so it cannot leak to other jobs. When ``None``, the existing uncapped behaviour applies. NrrxTF)read_cancel_stateu9[RUN-CANCEL] 배치 정지 — %s 앞에서 멈춘다. %su주행 정지 요청 (rsrzu2Step %s skipped (cascade) — upstream blocked: %s#requires_projection_sync_before_runu9Required pre-sync failed before %s: %s — aborting batchzPre-sync failed before z: )rjrdonez Step %s: %s)rSuAPost-step sync failed after %s — DB projection may be stale: %sfailedz!Step %s failed, stopping pipelinezStep z failedpartialallow_partial_downstreamuHStep %s partial and allow_partial_downstream=False — stopping pipelinez) partial (allow_partial_downstream=False)uCStep %s partial — continuing (downstream may use partial results)zstep.cancelledu)주행 정지 — %s 에서 멈춘다: %sz gate.blockeduFStep %s blocked: %s — downstream depending on this will cascade-skipzStep %s error: %szStep %s crashed: %sz crashed: uPipeline finished with %d blocked step(s): %s. Downstream skipped via cascade. Hint: missing dependencies may be in another category — try category='all'.u[RUN-CANCEL] 주행이 정지 요청으로 멈췄다 — %s. 다시 돌리려면 POST .../steps/cancel/clear 로 표를 내려라.r cancelledu 정지 요청okoutcomerzFinal sync failed: %szFinal sync failed: rOzPipeline failedzrun_steps_batch outer error: %s)rr rryrapp.core.run_controlr requestedrBrCdescribercrrrrrrruninforr`ralenrfrcloserrr1)r+r5step_idsrun_moderrbudgetr4failure_messageryall_okr blocked_stepsrNr cancel_state step_metar blocked_depssync_excrunnerrraer outer_excs r9run_steps_batchrs6v B%)OK< #&% C ?,RZHL%%O..0 ! $:<;P;P;R:SST"Un -c28b ,5==r+Ja+JaaS`N`+J aNNL\"%%c*==!FN -j*bI)Z^\ 2Hf5 M37==!FN &-j*bRUVX%LL!DcJ"F(-cU'&:Oy(!}}%?F%O f"'#C5(QR(NN]CF  LL`M"F=$9   NNX4#4  .b*o NK-@B@      ? D%j*bA;"E"      ! /J D3D  H-B1BD      I b%  W$  !&,CC58**U D%& +,/ &@ 77.. NN#NPSUWU_U_` $I&(jjO77n,NN`RZZ"%%c* 0#rzzB$)#b "=  2C=$)#j">  D D 4h? 2 &9($D $$7z"BDD&      9 D" L 6 B  KKM    +2z3y>JC NKK      L      s}A4S  M!0 K:K>,M!*S +M!> K AM!)L#8#M!S 7M!S M!,A S *S - Q.:S S M! L #1LM!S L  M!# M,'MM!MM!! Q+*>P2(S /AP20S 65P2+S 2 Q+>!Q&S &Q++S . S7>S5S6S SS U,)U'TU' TU'T'U'U,U/'U,,U//V)rrc ddlm}ddlm}ddlm}|j |j|jk(|jk(jj}|std|ddd}|jd k(rNdd lm t! fd t"D}|rtd |d d t$j'dd}|j(std|ddddlm} | std|dd|rdn |j} d |_ d|_|j1| S)u분석 시작 preflight — /analyze와 /steps/run-all 공용 (Codex W1 Critical 수정). 1. Episode row lock 2. status != "analyzing" 검증 (이미 실행 중이면 409) 3. fulltext 존재 검증 (없으면 400) 4. OPENAI_API_KEY 설정 검증 (없으면 400) 5. status='analyzing', analysis_error=None set + commit (race window 종료) Returns: prior_status — dispatch 예외 시 복구에 사용. 호출자가 rollback 책임. rr)trepisode.not_foundrr_Fris_task_runningc 3@K|]}ddd|yw)run_all::N).0catr5rr+s r9 z+preflight_analysis_start../s1 . hzl!J>L GN!GIIK r;c|yddlm}|j|j|j|k(j }|r||_|jyy)u;preflight 이후 dispatch 실패 시 episode.status 복구.Nrr)r&rr'r(r)r*rr)r4r5rrrs r9rollback_episode_statusr RsS * '  ! !'** ": ; A A CB     r;c|yt} t||||jy#|jwxYw)u세션이 죽었을 때 **새 세션으로** 상태를 되돌린다 (best-effort). 실패를 일으킨 세션이 DB 오류로 못 쓰게 됐고 `db.rollback()` 마저 실패한 경우다. 그 세션으로는 아무것도 못 하므로 새 세션을 연다. N)r r r)r5rsessions r9_rollback_episode_status_freshr bs8nG\B  s -?F)rr run_inline claim_held_byc ddlm} tD]!} | d|d|d| stddddd lm} md||d ur1| |d| s"dd lm} tdd | xsddds)dd lm} | } | |k7rtdd| xsdddd } |tvr t|||}t|||}t||}t|||||}t|||}d|d|d|}tjtfd}|||||||f}|rM||xsdddd}t!|j#d|j#dd|j#dd||dSt%|||d |d!|"}|stddd d#d'||d(S#t&$rd#} |j)n)#t&$rd}t*j-d$|d#%YnwxYw |rt/|||n t1||n(#t&$rt*j3d&||d#%YnwxYwr#r wwxYwwxYw))u카테고리 단위 run-all — 단일 진입점. ``run_inline`` — 배치를 **이 스레드에서 끝까지** 돌린다. 프로젝트 대기열이 여러 편을 순서대로 돌릴 때 쓴다. 배경 작업으로 던지면 바로 돌아오므로 「앞 화가 끝난 뒤 다음 화」를 만들 수 없다. ``claim_held_by`` — 호출자가 **프로젝트 자리를 이미 들고 있다**는 표시. ★대기열이 화마다 자리를 놓았다 잡으면 그 틈에 단일 실행이 끼어들어 순서를 깨고 canon·장부를 갱신한다 (Codex BLOCK 2026-09-04). 대기열은 자리를 **처음부터 끝까지** 들고, 안쪽 화 실행은 그 자리를 물려 쓴다. API 엔드포인트(run_all_steps, /analyze) 공용 dispatch 헬퍼. category가 analysis/all이면 preflight 포함 (Codex W1 Critical 수정). W20E5: when ``category in {"image", "all"}`` and ``settings.background_render_reference_mode == "shot_aware_plan"``, the caller must explicitly pass ``approve_image_generation=True`` and a positive ``image_call_cap`` or the dispatch raises before any background job is submitted. The budget is then installed on the worker thread so every provider call site reserves against it. rrrrstep.already_running!파이프라인 이미 실행 중rr_claim_episode_runrelease_episode_runNholder)episode_run_holderuT이 프로젝트에서 이미 다른 화가 돌고 있습니다 (먼저 잡은 쪽: ?u(). 여러 편은 순서대로 돕니다.zstep.claim_not_heldu8자리를 물려받았다고 했는데 실제 주인은 u없음u 이다)rdrrrqcL t|r SS#r wwxYw)uO배치가 끝나면 에피소드 자리를 놓는다. ★놓는 자리가 여기여야 한다 — 아래 `submit_background_job` 은 제출만 하고 바로 돌아온다. 제출 직후에 놓으면 배치가 도는 동안 자리가 비어 두 번째 요청이 그대로 들어온다. r)args _own_claim episode_keyrs r9_run_then_releasez0dispatch_category_run.._run_then_releases3 5&- ' 4:' 4s #Fru.run_steps_batch 가 결과를 안 돌려줬다rrrrr)rrrstepsjob_keyzRun all z steps for r!targetr descriptionTu>dispatch 실패 정리 중 세션 rollback 실패 (episode=%s)exc_infoudispatch 실패 정리 중 episode.status 되돌리기 실패 (episode=%s, 되돌릴 값=%s) — 원래 예외를 그대로 올린다startedrrr r!)rrrrrrr_ANALYSIS_CATEGORIESrrrErr: functoolswrapsrboolrcrrrrBrCr r r)r+r5rdrjr4rrrrr running_catrr_holderrrrrrr!r_argsrr'session_usablerrrs @@@r9dispatch_category_runr1tsAB7. Xj\:,a }M N+; /NZL)K$&J+ :,az :<='''9+'F'M#&NO89   =$[1 m #*S#/x09 ! !#'Lu + +3B JOL 1)%=  1Z@-  H$ *"j*E ZL*QxjA  ) 5 * 5"  (/LJ4LGw{{401%kk)X>%kk(B7%'; ;($"8*K |D   +; d  W ) + KKM +"N NNPT  + +  1'J E/z<H 9 LLZL4  9  9#K0 #K0O)sm&CF%8%F%% I 1GI #G(%I 'G((I ,H H< "H.+H<-H..H<1 I < I  I c  ddlm}tD]!}|d|d|d|stddddd lm}m}md| | d stdd | xsd dd t||}t||}t|||} d|d|d} tjt fd} t| | |||d|| fd|} | stddd dd|| dS#t$r  wxYw)uR씬 재분석(reanalyze-scenes) dispatch — scene_save + downstream force 실행.rrrrrrrr_)rrrrruC이 에피소드는 이미 실행 중입니다 (먼저 잡은 쪽: rrsz :reanalyzecB t|y#wxYwNr)rrrs r9rz4dispatch_scene_reanalysis.._run_then_releasews" 1&#K0#K0s r]zReanalyze scenes for episode r"Tr'r()rrrrrrrrErr:r*r+rrr)r+r5r4rr-rrrrrr!rr'rrs @@r9dispatch_scene_reanalysisr5Mst 7. Xj\:,a }M N+; / ZL)K [ ='''9+'F'M#&NaQ   0Z@0Z@)"j*E ZL*Z@  ) 1 * 1 ($j(G^ 7 |D  +;    K( s )A8C))C<queuedblocked_by_previousc ddlm}|stddd|j|j |j k(|j j|j|jj}|D chc]} | j } } |D cgc] } | | vs|  } } | rtdd| d d d |D cgc]} | j} } t| D chc]} | j| d kDs| c} }|rtd d|dd|D cgc]} | jdk(s| }} |rtdd|djdd|D cgc]} | j | jfc} tjt j"j%}|D]} t&| _ || _|j+d}dfd}t-||dt/d}|sb|D]?} d| _ tjt j"j%| _A|j+tdddddD cgc] \}} || d c} }d Scc} wcc} wcc} wcc} wcc} wcc} wcc} }w)!u여러 편을 **화수 순서대로 하나씩** 돌린다. ★``image_call_cap``·``approve_image_generation`` — 단일 실행과 **같은 인자**를 받는다. 없으면 `category="all"` 은 착수 검사에서 선다 (이미지 생성은 사람이 명시로 켜야 한다). 대기열이라고 그 문을 비켜 가면 안 된다. ★★``image_call_cap`` 은 **화당** 상한이다 — 대기열 전체 합이 아니다. 화마다 새 예산이 깔린다. N편을 넣으면 최대 `N × cap` 이다. 이 말을 안 적으면 승인한 수와 실제로 살 수 있는 수가 갈린다. ★왜 순차인가 — 앞 화가 끝나야 `entity_canon` 이 서고, 그래야 다음 화가 앞 화 명부를 보고 같은 신원으로 이어 붙인다(`episode_carry`). 나란히 돌리면 둘 다 백지에서 시작해 같은 것을 두 신원으로 만든다. 게다가 `short_id` 장부와 canon 이 프로젝트 범위라 동시 쓰기가 부딪힌다. ★다른 프로젝트끼리는 그대로 나란히 돈다 — 자리는 프로젝트마다 하나다. ★앞 화가 실패하면 뒤 화는 `blocked_by_previous` 로 **선다.** 자동으로 넘어가면 앞 화 없이 만든 신원이 그대로 굳는다. rrz queue.emptyu#넣을 에피소드가 없습니다r^r_ru)이 프로젝트에 없는 에피소드: Nrrzqueue.duplicate_episode_numberu화수가 겹칩니다 uU — 순서를 정할 수 없습니다. 화수를 고친 뒤 다시 넣어 주세요.rru*이미 도는 중인 화가 있습니다 (u화)rz run_queue:zqueue:c dddlm}ddlm}m}d}|| sJt j dD].\}}|} t||t|j0yd} D]\}}|} |#t||t |j3t| |d  } | xsijd sH|}t j d || xsijd d t| xsijdd|j ||y#|jwxYw#t$rA} |}t j d|t| dt||t| Yd} ~ vd} ~ wwxYw#|jwxYw#||wxYw)uT앞 화가 **끝난 것을 확인하고** 다음 화. ★배경 작업은 하나다.rr rrruF프로젝트 대기열 %s: 자리를 못 잡아 시작하지 못했다NT) r+r5rdrjr4rrrrruX프로젝트 대기열 %s: %d화가 %s 로 끝났다 — 남은 화는 %s 로 둔다: %srrrruQ프로젝트 대기열 %s: %d화에서 멈춤 — 남은 화는 %s 로 둔다: %sr%)app.core.databaser rrrrBr _mark_statusEPISODE_STATUS_BLOCKEDrr1rcr_mark_failed_if_still_queuedr1)r rr project_keyrM_nr  stopped_atnumberoutrrrd claim_ownerrrjrr+s r9_drainz&dispatch_project_queue.._drains2 A! - ![A LLa# %"R&.$ #/EFMMO # $( ' -& V&."$!-$Wc3IJ >MMO=0#-#!)#'{'51I C I2??40%+  01;V YBOOHc:2SYBOOHb4Q S"MMOI 'L ,UMMO8! I!'JLLk"F,BC!%!'1#s3xHH IMMO  ,s[D.,F%<EF%!A1EF%.E F  7FFF  FF""F%% F/zRun z episodes in order for )r!r#r$uploadedu;이 프로젝트의 대기열이 이미 돌고 있습니다Tr6)r5episode_number)rrepisodes)r&rrr'r(r+r)in_order_byrGrrfcountrrr.rr/ isoformatEPISODE_STATUS_QUEUED updated_atrrr)r+ episode_idsrdrjr4rrrrowsrfoundr_numsn_dupesrunningr. queue_keyrEr'rMrDrs` `` `` @@r9dispatch_project_queuerWsD+ M3X#&( (  ""j0'**..2M N '(( )    4aQTT4E %8+Q%q+G8$? }M  (, ,t!Q  tE , <1Q!);Q< =F 1.vh7EF   :$Q!((k"9q$G:'@AZAZ@[[_`  266Aa&&'6G ,,x|| $ . . 0C ( IIKZL)I:,'K;-;-z$&3w<.(? |LNG A!AH#<< 5??AAL 2\#&( (('.0'.VS!),qA'.0 11Y !8 -<;7l0s<J) J!3J!J&1J+ J+.J0J0.J5J: cddlm} |j|j|j|k(j }||j tk7ryd|_|dd|_tjtjj|_|jy#t $r+|j#t$j'd|dYywxYw) u\착수 전에 터진 화를 `error` 로. ★이미 다른 표가 있으면 안 건드린다.rrNriu실패 표 기록 실패 (%s)Tr%)r&rr'r(r)r*rrMrrr.rr/rLrNrrrrBrC)r r5rrrUs r9r>r>@s+ SmmG$++GJJ*,DEKKM ;#**(==  #DS\!hll3==? S6 TRSsAB1AB111C%$C%cddlm} |j|j|j|k(j }|t jd||y||_|xs1tjtjj|_|jt j!d||y#t"$r,|j%t j'd||dYywxYw) uK상태 한 칸만 바꾼다. 실패해도 대기열을 멈추지 않는다.rrNuB에피소드 상태를 못 적었다 — 행이 없다 (%s → %s)u에피소드 상태 %s → %su-에피소드 상태 기록 실패 (%s → %s)Tr%)r&rr'r(r)r*rBrrrr.rr/rLrNrrrrrC)r r5rr.rrUs r9r<r<Rs+&mmG$++GJJ*,DEKKM ; LL]#V -  F X\\ : D D F 3ZH &F TZ $  &&sACA(C2C;:C;)r4 OrmSessionr+r1r5r1returnDict[str, str])r4rZr+r1r[Dict[str, Any])r4rZr+r1r[r,) r4rZr+r1r5r1rSr1r[r,) rg List[str]rhrrir]rjr1rdr1r[None) r4rZr+r1rdr1r5 Optional[str]rjr1r[r^)r4rZr+r1r[r^r4) rSr1r+r1r5r1r4rZrr]rzOptional[Dict[str, str]])r4rZr5r1rr1r[r_)r4rZr5r1rr1r[r_)rdr1r Optional[int]rr,r[Optional[ImageCallBudget])r+r1r5r1rr^rr1rr]rr\rrbr[r])r4rZr+r1r5r1r[r`)r4rZr5r1rr`r[r_)r5r1rr`r[r_)r+r1r5r1rdr1rjr1r4rZrrarr,rr,rr`r[r])r+r1r5r1r4rZr[r])NF)r+r1rOr^rdr1rjr1r4rZrrarr,r[r])r rZr5r1rr1r[r_) r rZr5r1rr1r.r`r[r_)?__doc__ __future__rr*r?loggingr2rrtypingrrrr r sqlalchemy.ormr rZr;r app.core.errorsrapp.core.image_call_budgetrrrapp.core.job_managerrapp.core.step_catalogrrrapp.services.checkpoint_syncr getLogger__name__rBr__annotations__r:rErIrVr[rorrrrrrrr)rr r r1r5rMr=rWr>r<rr;r9rps|#  '330*$ 7 ?   8 $,UT #144*7!! #!14!?B! !,\\\\ \  \65 5 5 !5   5  5  5 z!% QQQQ  Q  QQhD.2 ! !!!  ! # ! + !H #47 4 #-0 :9494"94# 94  94F)-jjjj j # j ! j &jjZ+EEEE EP        2%)%*#'VVVV  V  V"V#VV!VVrGGG G G\!/%)%*\1\1\1\1  \1  \1 " \1#\1\1~S),S15S&'+&#&/3&r;