%j,<dZddlmZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z ddl mZmZmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddl m!Z!ejDe#Z$ddZ%ddZ&GddZ'y)uReferencePhase1Service — Phase 1 (base reference) 단독 서비스. F24.4.2 (2026-04-24): `ReferencePipelineOrchestrator.run()`의 Phase 1 루프 (batch 단위 base reference 이미지 생성 + early return)를 literal lift. 반환: - None: Phase 1 성공 or 0건. 다음 Phase로 진행. - Dict: Phase 1 부분 실패. orchestrator가 early return. - raise AppError: Phase 1 전체 실패. ) annotationsN)ThreadPoolExecutor as_completed)datetimetimezone)Path)AnyDictOptional)Session)AppError)to_relative_image_path)annotate_generated_asset)bind_current_budget)ActivityLogger) ImageAsset)ReferencePipelineContextcdtjtjj SN)rnowrutc isoformat[/Users/manta/Documents/Projects/TheRoad-I1/backend/app/services/reference_phase1_service.py_nowr"s << % / / 11rc<ttjSr)struuiduuid4rrr_new_idr!&s tzz| rc4eZdZdZ ddZddZy)ReferencePhase1Serviceu=Phase 1: 엔티티별 base reference 이미지 병렬 생성.c<||_||_||_||_yr)_db _project_id _actor_id_logger)selfdb project_idactor_idactivity_loggers r__init__zReferencePhase1Service.__init__-s!%!& rc  !"#$%&'()*+,-./ddlm(ddlm mm!m)m+ddlm }t|}ddl m }|j|j/|j}|j %|j"}|j$}|j&$|j(,|j*}|j,#|j."ddlm.|j4*|j6'|j8-|j:} |j<} |j>} |j&|j@} |jB} |jD}tG|D]\}}|Dcgc])}|%vr#||vr||vr%|jId|vr%|+}}|s>| jKd|jL| zd tO| |jL| !"#$%&'()*+,-./fd }tQtS| tO| 5}tU|}|Dcic]}|jW|||}}tY|D]} |j[\}}t]|jId d }|j_r|ja,|<jbjetfjitfjjjk(tfjl|dk(tfjndk(jKdditg|djd|d&tq|d |d|d|d|jId|jIdd|d }jbjs|tu|dg| | ijbjw|xjLdz c_&|jy|d|dd |d  | i| jKd|jL| zd tO| d%jI|ijIdd |jL| ddd|jLdkDrF|j|jLk(r-| jd!td"d|jd#d $|jdkDrdt|jd%|j| j|jL| | |jtO| d|jd&d'Sycc}wcc}w#tz$r|}||}|jIdd }t|jd|jId|||j|t|dd |xjdz c_BYd}~wd}~wwxYw#1swYlxYw)(Nr)generate_and_validate_reference)GROUNDING_INPUT_DIGEST_KEYGROUNDING_INPUTS_KEYGROUNDING_REFERENCE_LABELgrounding_input_digest provenance_of)canonical_ref_owner_types) load_printed_prop_anchor_context)reference_entity_type entity_typeu참조 이미지 /c$j|dt}t|xr|jddk(}|dv}|Dcgc]Y}|vrS|r'|s%dj|ijddn$dj|ijdd|f[}}|jdxs|jd xs|d}|jd d}|jdd k(rz#rx#jd xsij|jd xsd}|r?d dlm} | ||}| ||d}t j d|jd |rh|jddk(rT|sR|Dcgc](}|vr"j|ijdd*} }ddj| d} | |z}| |z}j|jd xsdxsdD cgc] } | df } } |dv}!|jdd||}|d||| || zxsdd"jd|dd }dtd|dddddd|dd |d!|d!d"dd#dd$d%d&tj|jd'id(d)|jd'ijd*d+tj|jd xsdxsgj|jd xsdxsgi}|d|fScc}wcc}wcc} w),Nidr9 characteruBase form — KEEP THIS FACE: namez Reference: t2i_prompt descriptionpropby_propshort_idr)build_prop_ref_prompt_overlayF)include_framinguMvisual_continuity_anchor: prop %s ref prompt overlay 적용 (canon 비변경)u'CRITICAL — This is a VARIANT form of z, z. The reference image shows the base form. Keep the EXACT same face, bone structure, skin tone, and identity. Only change what the description below specifies. rbytes)is_body_identityis_null_outlookref_image_gen_phase1)r+ episode_idoperation_type entity_id) gemini_client entity_nameentity_descriptionr9r@ output_dirextra_references style_context trace_metarM asset_type referencestill_id file_path prompt_usedgeneration_modelwidthheightstatus generated review_notes validation) ensure_asciivalidation_scorescore created_at) getsetbool2app.modules.pipeline.visual_continuity_anchor_planrEloggerinfojoinr&r!jsondumpsr)$entity entity_deps is_variantrIddep_refst2idesc_anchorrE base_namesvariant_instructionggrounding_refsrHref_entity_type pipe_resultresultr2r1r3_body_identity_ids _o00_char_idsdeps entity_by_idrKrNr0r4grounding_referencesr5 ref_image_map reference_dirr8r) vca_prop_ctxs$ r_gen_refz,ReferencePhase1Service.run.._gen_refrs"hhvd|SU; !+.[6::m3LP[3[ "(,-"?)  )A,>#?6l6F6Fq"6M6Q6QRXZ\6]5^_"<#3#3Ar#:#>#>vr#J"KL"1%') jj.]&**]2K]vV\~zz-4::m,6<+// :@bEE :.4"6G"/ &v'+ /",&.&?%HD"$'+&6&6&0*@%+D\   $') +[!9!3& 4F(GTdk"DJJ{|R/P_d$e&  b(I(M(Mg(V $&(-,00J1G1M2NTRT+V/0F,00J1G1M2NTRT1V%*d|V++I@"N "s AM-M  M) max_workersrXr?rM is_primaryr<rVrYrZr]r_rbrd) r<r+rUrMrKrXrYrZr]r_rbrrdreference_face) pipeline_roleinput_image_idspipeline_metadataasset_idz: r>zRef image failed (%s): %siu2참조 이미지 생성 전부 실패 (API 오류)zimage.all_ref_failedu=개 모두 실패했습니다. API 상태를 확인하세요.)codemessage status_codeus참조 이미지 %d개 실패 — 합성 이미지 생성 건너뜀. resume으로 참조를 먼저 완성하세요.u,개 실패. resume으로 재시도하세요.)r^skippedlow_freq_skippedfailedtotalr)F'app.modules.pipeline.ref_image_pipeliner03app.modules.pipeline.grounding_canonical_ref_inputsr1r2r3r4r5.app.modules.pipeline.grounding_entity_contractr6rf,app.core.steps.visual_continuity_anchor_stepr7r&rKbatchesr already_donelow_freq_skip_idsrrref_cp o00_char_idsbody_identity_char_idsapp.core.body_identityr8rrNrmax_concurrentprogressentities skipped_countr total_to_gen enumeratereupdategenerated_countlenrminrsubmitrr|rexists read_bytesr%queryrfilterr+rMrraddrcommitmark_completed Exceptionriwarning mark_failedr failed_counterrorr complete)0r)ctxr6_canonical_owner_typesr7rr_low_freq_skip_idsrrrrrrr batch_idxbatcheidbatch_entitiesrexecutor_submit_gen_refefuturesfuturer|fpassetexc failed_entity eid_failedr2r1r3r}r~rrrKrNr0r4rr5rrr8rs0` @@@@@@@@@@@@@@@@@rrunzReferencePhase1Service.run9s[   "%%>%@!A  88H8H#..Y ++'' ''  22xx)) ((  77@"77)) )) ++<<<<^^ )) //'' )' 2 Iu-2-2c,&3l+B11 %))-8a8???A>A>Z*73F4.&,mmo V!&**[""=>99;13M#.z299&11T5E5EE&00F;4GG&11Q6!&,!23 *%d|8H8HU`&,[&9j&rsg #  ?'&&0$6H:6)L   8 $2FFr