mCj dZddlmZddlZddlZddlmZmZmZm Z eje Z ddddd ddZ y)uFinal-asset lineage annotate — persist-all Wave 1. 이미 전용 등록 경로(reference_phase1/2/3, image_steps state_variant, scene_persistence, floor_plan_render, background_render 등)로 ``image_asset`` 에 insert 되는 **최종물**에, 캔버스 lineage 컬럼을 **보강(annotate)** 한다. ★중복 0 원칙(Codex 합의): capture sink 의 신규 insert 와 섞지 않는다. 본 함수는 기존 ImageAsset row(또는 commit 전 in-memory 객체)에 컬럼만 채우며, ``is_intermediate`` / ``asset_type`` 을 건드리지 않는다 (최종물은 영원히 is_intermediate=False 유지). commit 은 호출자가 한다. 설정 컬럼: pipeline_role / stage / input_image_ids(UUID-only) / generation_call_id / pipeline_metadata_json(merge). ) annotationsN)AnyDictListOptional)stageinput_image_idsgeneration_call_idpipeline_metadatac8 ||_||n||_|O|Dcgc]*}|t|js t|,}}t j ||_|||_|rfi}t|dd} | r( t j| } t| tr| }|j|t j |d|_|Scc}w#ttf$ri}YGwxYw#t $rt"j%d|dY|SwxYw)u최종 ImageAsset 객체에 lineage/role 컬럼을 보강한다 (non-fatal, no commit). Args: asset: ImageAsset ORM 인스턴스 (commit 전/후 무관). pipeline_role: 캔버스 색/필터용 역할 (reference_face / reference_outlook / reference_composite / character_state_variant / scene_still / floor_plan / background_render 등). stage: 파이프라인 stage 라벨 (없으면 pipeline_role 재사용). input_image_ids: 입력 이미지 **asset UUID** 리스트(구조키/경로/라벨 금지). None=lineage 미상(루트), []=입력 없음을 명시. None/빈 문자열 원소는 제거. generation_call_id: llm_call_log 연결용 call id. pipeline_metadata: 추가 메타(기존 pipeline_metadata_json 에 merge). Returns: 같은 asset (체이닝용). 예외는 삼키지 않고 로깅 후 asset 반환(non-fatal). Npipeline_metadata_jsonF) ensure_asciiz3annotate_generated_asset failed (non-fatal) role=%sT)exc_info) pipeline_rolerstrstripjsondumpsr r getattrloads isinstancedict ValueError TypeErrorupdater Exceptionloggerwarning) assetrrr r r xcleanedexistingrawparseds Y/Users/manta/Documents/Projects/TheRoad-I1/backend/app/services/image_capture/annotate.pyannotate_generated_assetr&s 2 +$0em  &'6[!!-CPQFLLNs1vG[$(JJw$7E !  )'9E $ ')H%!94@C"!ZZ_F!&$/#) OO- .+/::hU+SE ( L/\#I."!H"   A=   L  sPC4CC C 8C4'C)-C4C4C1.C40C11C44!DD)rrrrr Optional[str]r zOptional[List[str]]r r'r zOptional[Dict[str, Any]]returnr)__doc__ __future__rrloggingtypingrrrr getLogger__name__rr&r%r1s # ,,   8 $ +/(,265 55  5 ) 5 & 505 5r0