-ǚj_dZddlmZddlZddlZddlZddlmZmZm Z ddl m Z ddl m Z mZddlmZmZej$eZddZd Zdd Zd Zdd ZGd deZy)uEntitySyncService — entity_t2i 체크포인트 → EntityCanon + EntityEpisodeLink UPSERT. 기존 `steps.py:_sync_checkpoints_to_db` line 806-905에서 이관. ) annotationsN)AnyDictTuple)AppError) OWNER_PREFIXsplit_final_id)BaseSyncServiceis_cp_syncablec0ddlm}t||S)u이 CP 에서 **읽고 지울** 갈래 키들 — ★**한 벌**이다. ★★★앞 판은 **조회만** `location_part` 까지 넓히고 loop·pre-scan·stale cleanup 은 옛 셋 그대로 뒀다. 그러면 LP link 가 `_existing_links` 에는 들어오는데 `_seen_canon_ids` 에는 **절대 안 들어와** stale cleanup 이 **그것을 지운다** — 실제 데이터 손실이다 (Codex BLOCK 2026-09-01). 그래서 이 함수 하나가 **읽는 자리와 지우는 자리에 같이** 쓰인다. 표식 없음 → 옛 C/L/P 그대로 (legacy 동작 **무변**) 표식 = 아는 판 → C/L/P/LP 표식 = 모르는 판 → **선다** (`UnknownChunkSchema`) r) owner_keys).app.modules.pipeline.grounding_entity_sync_extr list)t2i_cpr s f/Users/manta/Documents/Projects/TheRoad-I1/backend/app/services/checkpoint_sync/entity_sync_service.py _sync_keysrsJ  6" ##cddlm}|S)Nr resolve_canon)rrrs r _resolverr's L rcddlm}|jDcic]\}}|| }}}|Dcgc]}|| c}Scc}}wcc}w)uJ복수 키 → 갈래 이름. ★표를 여기서 다시 적지 않는다.r)CHUNK_OWNER_KEYS)rritems)keysrkvbacks r _singularsr-sQ.335 65TQAqD5D 6! "TDGT "" 7 "s = A)z{}z[]Nc d}|jD]6\}}t||d}|tvr|dz }!|tvs*t|||8|S)u비어 있는 칸만 채운다. 채워져 있으면 **손대지 않는다**. Returns: 보존한(=안 덮은) 칸 수. 0 이면 이번 화가 처음 채운 것이다. rN)rgetattr_BLANKsetattr)rowfieldskeptkeyvaluecurs r_fill_blank_fieldsr,;sZ Dlln Uc3% f  AID    Ce $ % KrceZdZdZddZy)EntitySyncServiceuentity_t2i 체크포인트 기반 canon/link UPSERT. - C/L/P 엔티티만 대상 (outlook은 OutlookSyncService에서 처리). - 기존 link의 t2i_appearance_count 등 메타데이터 보존. - 체크포인트에 없는 link만 제거 (다른 step의 link는 보존). czDddlm}m}|jd}t |}t |}ddlm}|t||stjdddddS|jdd k(}|jd i}|jj|j|j|jk(|j j#|j%} | D cic]} | j&s| j&| } } t)| } i} | D]9} | j+| j | j,fgj/| ;| Dcic]}|j,|}}| Dchc]}|j0}}|r|jj|j|j|jk(|j2|j2k(|r|j4j#|nd j%Dcic]}|j4|c}ni}t7}t9j:Dcic]}|dc}Dd6Dfd }| D];}|j&st=|j&dkDs)||j&d =|D]F}|j|gD]/}|jdd}|st=|dkDs'||d1Ht7}|D]?}|j|gD](}|jdd}|s|j?|*At7}|r|jj|j|j|jk(|j j#||j&j#|j%}|D]$}|j?|j0d|_&|r%|jjAt)| } ddlm!}tEdtG||D}tI} t7}!|r|jj|j4j|j|jk(|j2|j2k7|j4j#|j%D"chc]}"|"d }!}"t7}#i}$d}%d}&|D]\}}'}(|j|gD]}|d}) | tK|jdxsd|'|)| | }*|jd},|,'tOdd|)d|'d|jddd ||'|,|jddxs|)!tQjR|,d "}-|*ra|*j0}.|jdd}/|/r|/|*j&k7r |/|*_|*| |/<|*j0|!v}0|*j,|)k7r'|0r|#j?|*j0|)fn|)|*_t)|jd#d|jd$dtQjR|jd%gd "|-&}1|0r|%tU|*fi|1z }%n%|1jWD]\}2}3tY|*|2|3|jZ|*_.|)|jd#d|jd%g|jd$dd'|$|*j0<ntKt_j`}.|jdd}4|4sD|(xxdz cc<|(D|(d(}4t)|.|j|4|)|'|jd#d|jd$dtQjR|jd%gd "|-|jZ|jZ) }5|d7i|5}6|jj?|6|4r|6| |4<| j+|'|)fgj/|6|$j|.}7|7rtQjR|7d "nd}8|.|vrV|jj?|tKt_j`|.|j|j2|8*n |8 |8||._1|j?|.|&dz }&|#r dd+lm2}9|jj|9j|9j4j#|#D :chc]\} }:|  c}:} j%D;chc]};|;j4|;jff}<};ti|#D]K\}=}>|=|>f|,M|jjd-t=|#|%r|jjd.|%d}?|r&|jjd/t=|n=|jWD]*\}=}|=|vs |jjk||?dz }?,|jjA|r|jj|j|j0j#||j&jmdj%}@|@rA|jjod0t=@|@D"cgc]}"|"j0c}"dd1dd2l8m9}A A|j|j}B|Bju}C|Cr|jjod3C|jjd5|&|?|&|?ddScc} wcc}wcc}wcc}wcc}wcc}"w#tL$r}+tOddd|+|+d}+~+wwxYwcc}:} wcc};wcc}"w#tv$r&}+|jjyd4|+Yd}+~+d}+~+wwxYw)8z2Returns: {"synced": n, "removed": n, "skipped": n}r) EntityCanonEntityEpisodeLink entity_t2i)assert_matches_sync_ownersuKSkipping entity sync: entity_t2i 데이터 없음 (cascade or pre-analysis)r")syncedremovedskippedstatuspartialdataFct|xsd}|tjd||y|\}}t|}t j |d||<y)Nr z!malformed %s short_id skipped: %sr)r loggerwarningrmaxget)sidwheregotownernumprefix _counterss r_seedz5EntitySyncService.sync_from_checkpoint.._seedsY +C{BE3OJE3!%(F #IMM&!$z9EntitySyncService.sync_from_checkpoint..s) $6 X|H5 6$6sname)rH entity_typerP by_short_id by_type_namezentity_sync.identity_ambiguousizEntitySyncService: )code status_codemessage metadata_jsonzentity_metadata.shape_violationz/EntitySyncService.sync_from_checkpoint: entity z (z , short_id=z) missing metadata_json in entity_t2i checkpoint. Force re-run entity_extract / entity_t2i for this episode with Area B schema.)rTrV)rH) ensure_ascii description t2i_prompt visual_traits)rYrZ stable_traitsrW)rPrYr[rZ02d) id project_idrHrPrQrYrZr\rW created_at updated_at)r^canon_idr_ episode_idepisode_notes_json) EntityAlias)r^rbaliasu;재사용 canon 의 새 이름 %d개를 별명으로 보존ue기존 canon 의 안정 칸 %d개를 보존 (덮지 않음). 이번 화 묘사는 링크에 적었다ueEntity sync: partial checkpoint — upsert %d, stale cleanup deferred (awaiting completed checkpoint)uentity_canon orphan after sync — %d row(s) left short_id=NULL (cp swap took their short_id, no name match in cp). Downstream short_id lookups will silently miss these. ids=%s)ScenePersistenceServiceuyentity sync: cleaned %d orphan reference/composite asset row(s) (unexpected — investigate parent entity removal source)z2entity sync: orphan cleanup failed (non-fatal): %szISynced %d entities to DB from checkpoint (upsert); removed %d stale links)r?strr@rireturnNone)=app.models.projectr0r1_load_cprrapp.core.entity_metadatar3r r;infor>dbqueryfilterr_rQin_allrHdict setdefaultrPappendr^rcrbsetrvalueslenaddflushrJtupleziprri ValueErrorrjsondumpsr,rr%nowrauuiduuid4rdrerfsorteddeleteis_r<&app.services.scene_persistence_servicerhdelete_orphan_entity_assets Exceptionerror)Eselfr0r1r_keys_typesr3 is_partialr9 _canon_rowsc _by_short_id_by_original_short_id _by_type_nameeexisting_canons_clp_canon_idslnk_existing_links_seen_canon_idsprFetypeentr? cp_short_idssorphan_warn_ids conflictingr&rJ _TYPE_DEFSr_shared_canon_idsr _new_aliases_episode_notes _frozen_hitsr4rNrDrPrGexc_md_rawmetadata_json_strrbcp_short_shared_fields_k_vshort insert_kwargs_new_row_notes _notes_jsonre_a_havecidrfr5 still_nullrhspsremoved_orphansrEsE @rsync_from_checkpointz&EntitySyncService.sync_from_checkpointSs E|,6"E" H"$fe, KK]  A!< <jj*i7 zz&"%ggmmK077  " "doo 5  # # ' ' /  #% 0;I{!ajj A { I!%\ 257 A  $ $ammQVV%V[*ce * *#CLL# * "$  #u$0#6#6#89#8aQT#89  CAzzc!**o1ajj*-Exxr*ggj"-3s8a<#|,+  E Exxr*GGJ+ $$Q'+ #u ''-- 4;;&&$//9''++F3$$((6ce  # ##CFF+# #   $$9:  L $'v$6  " "% "ggmm,=,F,FGNN%00DOOC%00DOOC%..22>B#% !! ! E )+ '1 #E8Vxxr*6{ Q,!$SWWZ%8%>B!?$,4$0} NH''/2?">MdXV (zSWWZ5L4OP22  /g B0G0O4%)JJwU$K!'{{H"wwz26HH0A0A$A,4)19 X.'kk->>G}},"(,,hkk4-@A,0HM"$'GGM2$>#&77<#<&*jjGGOR8u'N&7 G$(:8(Ow(OO '.mmoFB#Hb"5'6*.((H'!%'*ww}b'A),")E&)gglB&? 3N8;;/ #4::<0HGGJ3E !&)Q.)#)(9V+#&77<#<&*jj"1M\a&b&7#'88%M +;];HGGKK).6 U+!,,h-=rBII(S(++H5"( $zz&uE.2?2GGKK 1tzz|,x#'??t+6! !,DOOH-@##H-! {+(2D  604ww}}[/I/P/P((,,L-ILDAqaL-IJ0LLOCE0R0R!QWW%0R %\2 U<5( K3tzz|+rsg#  ##$LN   8 $$& #   zDzDr