j-0dZddlmZddlZddlZddlZddlmZmZm Z m Z ddl m Z ddlmZdZdZd Zd d ZGd d eZy)u*EpisodeProjectionService — Episode status + T2I appearance count projection. 기존 `steps.py:_sync_checkpoints_to_db` line 1484-1495 + `_sync_t2i_appearance_counts` 702-773 이관. problems.md #12 (2026-05-02): step_run 의 실제 완료 상태를 반영하지 않고 무조건 ``ep.status='analyzed'`` 로 setting 하던 동작 제거. STEP_MANIFEST 의 active analysis step 들이 모두 completed/not_applicable 일 때만 'analyzed' 로 advance. ``settings.episode_status_strict_projection=False`` 시 옛 동작 보존 (즉시 disable 경로). ) annotationsN)AnyDictListTuple)text)BaseSyncServicez[strict-projection])1trueyeson)0falsenooffcfddl}tjjd}|a|j j }|t vry|tvry|jtjd|t tz ddl m }tt|ddS#t$rYywxYw) uproblems.md #12 toggle 평가. 우선순위: ``EPISODE_STATUS_STRICT_PROJECTION`` ENV → ``settings.episode _status_strict_projection`` (Pydantic) → default True. ENV 직접 평가는 운영자 instant-toggle 위해 보존. Review I2 — 인식 못 하는 ENV 값 (typo: ``"truee"``, ``"enabled"`` 등) 은 silent False 가 아니라 Settings default 로 fallback. typo 가 default safety (strict=True) 를 우회하지 않도록. rN EPISODE_STATUS_STRICT_PROJECTIONTFueEPISODE_STATUS_STRICT_PROJECTION=%r unrecognized — falling back to Settings default. Use one of %s.)settings episode_status_strict_projection)loggingosenvirongetstriplower_TRUTHY_VALUES _FALSY_VALUES getLogger__name__warningapp.core.configrboolgetattr Exception)_loggingrawvrs m/Users/manta/Documents/Projects/TheRoad-I1/backend/app/services/checkpoint_sync/episode_projection_service.py_is_strict_projection_enabledr*s **..; eZdZddZddZ d dZddd dZy) EpisodeProjectionServicecddlm}|jd}|jj |j |j |jk(j}|dgd}|s|Stsd|_ |j|_ |S|j}|d|d <|d |d <|drd|_ d|_n|j||d |j|_ |S) uVT2I appearance count + Episode.status conditional advance. Claude Phase 2 M2: 다른 Service와 이름 통일 (project → sync_from_checkpoint). Behavior (problems.md #12): - strict=True (default): STEP_MANIFEST 의 active analysis step 의 step_run.status 가 모두 completed/not_applicable 이면 status='analyzed' + analysis_error=None. 그 외에는 status 변경 안 함 + analysis_error 에 incomplete step 목록 (sample 5개) 기록 + logger.warning emit. - strict=False: 옛 동작 — 무조건 status='analyzed'. Returns: { "appearance_updated": int, "analysis_complete": bool | None, # strict=False 면 None "incomplete_steps": List[(sid, status)], # 빈 list 면 모두 완료 } r)EpisodeFcommitN)appearance_updatedanalysis_completeincomplete_stepsanalyzed all_completedr2r3)app.models.projectr.sync_t2i_appearance_countsdbqueryfilterid episode_idfirstr*statusnow updated_at_compute_analysis_completionanalysis_error_record_incomplete_analysis)selfr.updatedepresult completions r)sync_from_checkpointz-EpisodeProjectionService.sync_from_checkpoint@s& /111? WW]]7 # * *7::+H I O O Q")!% ""  M,."BI HHBMM668 &0&A"#%/0B%C!" o &"BI $B   , ,Rlen)rDrLrM_ACTIVE_LIFECYCLESsidinfocandidate_steps active_steps applicabilityexcrowsr status_map incompletests r)rAz5EpisodeProjectionService._compute_analysis_completionss, G8&Z"/!4!4!6 !6ICxx #z1h/3EE !6  #% "C - ;$//!  00    $#%)rSTU Uww +  OODOO\ R   (* 4884aaii)4 8,. C$B44   sBO)4 5  ",^ * -  ]  - ##Z!-  -,9s#4E"E0F F%F  Fc t|dd}|r<|jts'|jj d|j ydj d|ddD}t|dkDrdt|dz dnd }td t|d ||d }|dd |_|jjd|j |Dcgc]\}}| c}}ycc}}w)u`analysis_error 필드에 incomplete step 목록 기록 + logger.warning. Claude review I1 — 다른 caller (step_execution_service 의 partial-strict path 등) 가 이미 specific 에러 메시지를 set 한 경우 보존. strict-projection 이 자기 메시지로 덮어쓰지 않도록 prefix tagging 으로 식별. rBNuREpisode %s analysis_error already set by caller — strict projection preserves itz, c32K|]\}}|d|dyw)()N).0rfrps r) zGEpisodeProjectionService._record_incomplete_analysis..s!Hgc2cU!B4q>sz (+z more)rz Analysis incomplete: u" active step(s) not completed — zP. Episode.status NOT advanced to 'analyzed' (problems.md #12 strict projection).iu7Episode %s status NOT advanced — incomplete steps: %s) r$ startswith_STRICT_PROJECTION_PREFIXr^rgr<joinrdrBr!) rDrFroexistingsamplemoremessagerf_s r)rCz4EpisodeProjectionService._record_incomplete_analysiss2/6 H//0IJ KK  d  HBQHH47 Oa4GS_q()0R())?J?PQ006xv>N N  $ETN  E OO) *zVS!Sz *  +s C(Tr/cddlm}m}m}|jj |j |j|jk(|j|jk(|jdk(|jdk\|jdk7j}d d}i}|D]}t} tj|j xsd} | D]} || j'dd| | s)|j(|j*fD]} | s|| | | D]} |j'| dd z|| <|jj |j |j|jk(|j|jk(j}|Dcgc]}|j,}}|rQ|jj |j |j.j1|jng}d}|D]^t3fd |Dd }|r |j4s'|j'|j4d}j6|k7sS|_|d z }`|r|jj9|j:j=d |t?||S#tj"t$f$rg} YwxYwcc}w)uT2I 프롬프트에서 short_id별 출현 횟수를 카운트하여 EntityEpisodeLink에 저장. 카운트 단위: shot별 1회 (같은 shot의 variation N개에서 중복 → 1) 소스: SceneStill.t2i_variations_json 우선, 없으면 t2i_prompt_cinematic fallback 대상: selected / non-stale / still_index>=0 still 한정 (stale/비선택 still 제외) Returns: 업데이트된 link 개수. r)EntityEpisodeLink EntityCanon SceneStillTstalectjd|D]B}|j|jd|j|jdDtjd|D]"}|j|jd$tjd|D]"}|j|jd$tjd|D]"}|j|jd$y)Nz(C\d{2,3})(O\d{2,3})z(?._extract_sidss[[!8(C$$D[[!>I$J[[!6A$B[[!6A$BrJz[] t2i_promptrrc3VK|] }|jjk(s|"yw)N)r;canon_id)rvelnks r)rwzFEpisodeProjectionService.sync_t2i_appearance_counts..s!FX1E!Xs))NzDT2I appearance counts: %d entities updated, %d total short_ids found)rstrrset) r6rrrr8r9r:r]r< is_selected still_indexr>allrjsonloadst2i_variations_jsonJSONDecodeError TypeErrorrt2i_prompt_cinematict2i_prompt_closeuprr;in_nextshort_idt2i_appearance_countr0r^rgrd)rDr0rrrstillsr sid_countsstill shot_sids variationsvarfieldrflinksr canon_idsentitiesrEcanoncounts ` r)r7z3EpisodeProjectionService.sync_t2i_appearance_countss RQz*11  ! !T__ 4  ! !T__ 4  " "d *  " "a '    (  #%  % E UI !ZZ(A(A(ITJ "cgglB7C"#88%:R:RSE%eY7T!",..a"81"< 3! /077  ( (DOO ;  ( (DOO ;  #% .33UcS\\U 377==-44 NN  y ) #%" CFXFMENN5>>15E''50+0(1   GGNN   R S_ G(()4   4s3#K-K"KKN)returnzDict[str, Any])rFrrozList[Tuple[str, str]]rNone)r0r#rint)r __module__ __qualname__rIrArCr7rurJr)r,r,?s91fN `  #8  @<@FrJr,)rr#)__doc__ __future__rrrrtypingrrrr sqlalchemyrra"app.services.checkpoint_sync._baser rzrrr*r,rurJr)rsL # ))'>2,/ @jjrJ