gjo"lUdZddlZddlZddlZddlmZddlmZmZm Z m Z eje Z dZ ddlZdZdedefd ZGd d ZGd d ZdZdeeeffdZde edeeefdefdZde eeefde edeeeffdZdedeeeffdZdddddddddd dedededededeeefdede ed e e ed!e ed"ed#e ed$e ede eeefde ede ef d%Zddddd&ded$e ed#e efd'Zdae ee d(<ejBZ"defd)Z#y#e$rYwxYw)*ue이미지 생성 Opik 트레이서 — 메타데이터만 기록 (이미지 바이트 절대 첨부 안 함). 모든 이미지 생성 호출(Gemini T2I/I2I, fal.ai)을 감싸서 프롬프트, 참조 이미지 UUID, 생성 이미지 UUID, 파라미터, 에러를 Opik에 기록. thread-local context(StepRunner)가 있으면 자동으로 session 그룹핑. N)contextmanager)AnyDictListOptionalFTmodelreturnc|xsdj}d|vsd|vry|jdsd|vs|jdryd|vsd |vsd |vry y ) u모델 이름 → provider. 모르는 이름을 fal.ai 로 몰지 않는다. ★전에는 gemini/imagen 이 아니면 **전부 fal.ai** 였다. gpt-image 계열이 Opik 에서 fal.ai 로 잘못 적혔다 (Codex 리뷰 지적, 2026-08-07). geminiimagen google_aiz gpt-imagezdall-eopenaiqwenfluxfalzfal.aiunknown)lower startswith)rms R/Users/manta/Documents/Projects/TheRoad-I1/backend/app/modules/llm/image_tracer.py _provider_ofrs` "A1}A ||K K1$4 X8N {fkUaZ c6eZdZdZdZdeeddfdZdefdZdefdZ dd e d e d e d ee e d ee de dee de deee e fdeee e fdee deee e fdeeddfdZe dd e d e d e d ee e deee e ff dZy) ImageTraceru이미지 생성 호출 래퍼 — Opik span 자동 기록. Usage: tracer = ImageTracer() with tracer.span("ref_image_gen", model="imagen-3.0-generate-002", prompt=prompt, ref_image_ids=["abc123"]) as s: img_bytes, elapsed = gemini_client.generate_image(...) s.set_output(image_id="def456", duration_ms=elapsed) # 또는 단순 호출 tracer.log("fal_angle", model="qwen-image-edit-2511", prompt="H=15 V=-10 Z=1.0", params={"horizontal": 15, "vertical": -10, "zoom": 1.0}, ref_image_ids=["abc123"], output_image_id="def456", duration_ms=320) cd|_d|_tr d} ddl}ddlm}t |dd}t |ddrL|jjd|j|jjd|j|rtj||_ytj|_yy#t$rd}YFwxYw#t$r }tjd |Yd}~yd}~wwxYw) Nrsettingsopik_project_nameopik_url_overrider OPIK_URL_OVERRIDEOPIK_WORKSPACE) project_nameu6Opik client init failed — image tracing disabled: %s)_client_explicit_context_opik_availableosapp.core.configrgetattrenviron setdefaultr opik_workspace ExceptionopikOpikloggerwarning)selfproject_osrexcs r__init__zImageTracer.__init__<s 15  ^ #$8%h0CTJGx)z"ImageTracer.log..sD{!atmA{s rDrErJrGimage_idrH ImageGenErrorr )exception_typemessage traceback)rrIrCrIrropik_trace_v2_enabledF)build_axis_tags current_tracerolesuccess)rCoprrLrGu · llm) trace_idnametyperrLinputoutputmetadatarR/)rgrirjrkrRrP error_info)rgrhrrLrirjrkz&ImageTracer.log failed (non-fatal): %srU)r$r?getextendupdater(rr)app.modules.llm.opik_tracer`rarspanuid _usage_kwargsendtracer-r0debug)!r2rCrrDrErFrGrHrIrJrKrLrMrNr7rQ trace_input trace_outputrmtrace_metadata span_metadata span_tagsrr`rardaxisparentsrv span_kwargsr5rRs! @rlogzImageTracer.log|s@|| g H##%C -F1FJ%=Dwwv Ds6{DD#V,K/< O,(. H%,4f+=L+: Z(J(-ds W%0?ERVSVKfhi {DN%%n5+KJFLbJM$$^4.2I 1x!8%@4l''/74&"(*Il56I#)Y#64F '%) ))!' "t4w/"%!)!@\%-@),!.T (z:AEEG ! LL&&vQug&!#'$%'E$; U(;$&)+K$&/ F#   }UJ? @ )[)A EEG IIK H LLA3 G G HsF H2BH22 I;IIc #Kt}tj} | |js(ttj|z dz|_|j|||||j|j |j |j| y#t$r}t ||_d|_d}~wwxYw#|js(ttj|z dz|_|j|||||j|j |j |j| wxYww)uContext manager — 생성 후 결과를 set_output으로 기록. with tracer.span("scene_image_gen", ...) as s: img, elapsed = generate(...) s.set_output(image_id="xxx", duration_ms=elapsed) rHN) rCrrDrErFrGrHrIrJ) _SpanContexttime monotonicr-str_error_status _duration_msintr _image_id) r2rCrrDrErJr7t0r5s rrrzImageTracer.spansn ^^  I ###&(82(='E#F HHv+ # {{jj,,   SCJ!CK   ###&(82(='E#F HHv+ # {{jj,,  s5EBA7E C'B??CCA8D??E) NNrcNrNNNNN)NN)__name__ __module__ __qualname____doc__r6rrr9r?rBrrrrfloatrrrrrUrrrr)s$^>%x~%$%,d,&#T#.2)-#+/37"&*.&*JHJHJH JH  S * JH "# JHJH}JHJHc3h(JH!c3h0JH3-JHS#X'JHUOJH JHX .2+/ !!! !  S * ! c3h( !!rrc DeZdZdZdZdZ d deedededeefd Z y) ru5span() context manager 내부에서 결과 설정용.rrrrc<d|_d|_d|_d|_y)NrcrrrAs rr6z_SpanContext.__init__2s(,% %) !"rNrYrIrGrHc<||_||_||_||_yrT)rrrr)r2rYrIrGrHs r set_outputz_SpanContext.set_output8s!'  r)NrrcN) rrrr __slots__r6rrrrrUrrrr-sD?BI# MNCG8C=c3;C=rr project_id episode_idci ddlm}|}|dD]}t||d}|||<t fdtDsL ddlm }|xsi}tD].}j|r|j|s'|||<0 SS#t$r }tj d|Yd}~d}~wwxYw#t$r!}tj d|Yd}~Sd}~wwxYw) u;기록용 신원 메타를 **주변 scope 에서 직접 읽는다**. 근거 두 겹을 이 순서로 본다: 1. **이미지 포착 scope** — `still_id`·`shot_index` 까지 아는 가장 정확한 근거. 이미지를 만드는 자리에만 열려 있다. 2. **스텝 컨텍스트**(StepRunner 의 thread-local) — 신원 두 칸만 메운다. 검색처럼 이미지를 포착하지 않는 호출은 1번 scope 를 열 이유가 없어, 그것만 보면 `project_id`/`episode_id` 가 빈 채로 남는다. 실제로 검색 호출 기록이 그래서 비었고, **프로젝트 단위로 "이 검색이 살아 있나"를 물을 수 없었다.** ★인자로 받지 않는 이유 (2026-08-07): 이미지 저수준 함수는 호출 사이트가 여럿이라, 인자로 만들면 배선을 빠뜨린 사이트가 **조용히 기록 없이** 돈다. 실제로 gpt-image 경로 전체가 Opik·llm_call_log 양쪽에 한 줄도 안 남아 "작업이 살아 있나"를 볼 근거가 없었다. StepRunner 는 **모든 스텝**에서 컨텍스트를 설정하므로, 호출 사이트를 하나씩 배선하는 것과 달리 2번은 빠뜨릴 자리가 없다. ★2번의 한계: thread-local 이라 **worker thread 에는 자동 전파되지 않는다.** 지금 검색 호출자는 한 곳이고 병렬이 아니라 닿지만, 나중에 ThreadPool 로 나누면 신원이 다시 빈다. 그때는 1번처럼 명시 전파가 필요하다 (`bind_current_generation_context` 가 그 자리의 본보기다). r)current_contextN)rrstill_id scene_index shot_index entity_idstageu#ambient_call_meta 조회 실패: %sc3@K|]}j|ywrT)rn)rVkeymetas rrXz$ambient_call_meta..ms7txx}sr;u7ambient_call_meta 스텝 컨텍스트 조회 실패: %s) "app.services.image_capture.contextrr)r-r0rwall_IDENTITY_KEYSr=r<rn)rgctxrvaluer5r< step_metars @rambient_call_metarFs2D AF   Kc40$ %DI K 77 7 Y H-/52I%xx}s); )#DI& K4K A :C@@A Y LLRTW X X K Ys@#BB +C5C C B?B::B? C, C''C,fallbackambientc|jd}|r t|S ddlm}ddlm}|xsijdxsg}|D]A}t|}|j |s |t|dj}|s?|cS |xsdS#t$r } tjd| Yd} ~ *d} ~ wwxYw) u'스텝 이름 — capture scope 의 stage > thread-local Opik 태그 > fallback. ★ImageTracer 의 explicit context 는 **쓰지 않는다**. 그것은 process 하나에 공유되고 지워지지 않아서, 그 mixin 을 쓰지 않는 스텝의 호출이 **직전 스텝 이름으로** 기록된다 (Codex 리뷰 2026-08-07). ★2026-08-28 실측: thread 태그를 `tags[0]` 로 **그대로** 집어서 두 군데가 깨졌다. 그 태그는 이미 축 접두사가 붙은 `step:shot_conti_light` 라서 - DB `llm_call_log.step_name` 이 `step:shot_conti_light` 가 되고 (다른 행은 `scene_image_pipeline` 처럼 맨 이름이라 **같은 스텝이 두 이름으로 쪼개진다**) - `build_axis_tags(step=...)` 가 접두사를 한 번 더 붙여 **`step:step:shot_conti_light`** 가 된다 이번 완주 주행 Opik 실측 = 이중 접두사 span **6건** / 세 자리 (`shot_conti_light` 3 · `background_render` 2 · `floor_plan_render` 1). 그래서 **`step:` 축 태그를 골라 접두사를 벗겨서** 돌려준다. 순서에 기대지 않는다 — 종전에는 `_AXIS_ORDER` 가 step 을 맨 앞에 두는 덕에 우연히 맞고 있었고, 축 순서가 바뀌면 모델명·제공자명이 스텝 이름이 됐다. rrr;)STEP_TAG_PREFIXrRNu#resolve_step_name 조회 실패: %s image_gen) rnrr=r<rqrrlenstripr-r0rw) rrrr<rrRtagtextbarer5s rresolve_step_namerzs. KK E 5z AD>%'-2226:@bCs8D/C01288:K   "{" A :C@@As*A B,B BB C B;;CrMrNc >i}t|trP|jDcic].\}}t|ttfrt|t s||0}}}|r||d<t|ttfrt|t st ||d<|Scc}}w)uOpik span 이 받는 `usage` / `total_cost` 칸 — **있는 것만 넣는다.** ★0 을 채우지 않는다. provider 가 안 알려 준 값을 0 으로 적으면 「토큰을 안 썼다」로 읽히고, 그 0 이 합산에 섞이면 비용이 실제보다 작게 나온다. 없으면 **칸 자체를 안 만든다** — 그래야 나중에 「못 잰 것」과 「0 이었던 것」을 가를 수 있다. ★키 이름은 litellm 이 쓰는 것과 맞춘다(`prompt_tokens` / `completion_tokens` / `total_tokens`). 이름이 다르면 감사 도구가 같은 칸으로 못 읽고, 지금 openrouter 137 span 이 겪는 것과 같은 「기록은 있는데 안 세어지는」 자리가 또 생긴다. rMrN) isinstancedictitemsrrbool)rMrNoutkvkeeps rrtrts C%!&LAa#u.z!T7J1L CL*sEl+J 5!*-L JLs3Brespc^t|dd}|iSi}dD]<}t||d}t|ttfs't|tr8|||<>t|dd}| t|ddnd}| t|dd}t|ttfrt|ts||d<|S)uOpenAI 계열 SDK 응답에서 토큰 칸을 꺼낸다 — **캐시 칸까지**. ★캐시 적중이 여기 들어 있는데 지금까지 아무도 안 꺼냈다. 그래서 감사표가 판정 루프 캐시를 「0%」로 적었고, 나는 그것을 「캐시가 안 붙는다」로 읽을 뻔했다. 실측하면 grok 은 2,304/2,326 = 99% 적중이다. 없는 칸은 **안 만든다**(`_usage_kwargs` 와 같은 규칙). rMN) prompt_tokenscompletion_tokens total_tokensprompt_tokens_details cached_tokens)r)rrrr)rurrgrdetcacheds rusage_of_openai_responsers gt$Ay CF AtT " a#u &z!T/BCIG !,d 3C47OWS/4 0F ~OT2&3,' 640H%O Jr) ref_count operationrErHto_db output_textrLrMrNrCrDrGrIrrrrErHrrrLcvd}| r ddlm}||||dk(r| nd|||jd|jd|||r t|nd| xsijd| xsijd| |j Dcic] \}}|d vr||c}}xsd } tj||||r t|nd|| |||d || | | |Scc}}w#t $r }t jd |Yd}~bd}~wwxYw#t $r!}t jd|Yd}~|Sd}~wwxYw)uprovider 호출 하나를 DB(llm_call_log)+Opik 양쪽에 남기고 **호출 ID 를 돌려준다**. 이미지·검색·텍스트 어느 쪽이든 **litellm 을 우회하는 직접 호출**은 여기를 거쳐야 Opik 에 남는다(litellm 경로는 콜백으로 자동이다). 성공도 실패도 남는다. 어느 쪽 기록이 터져도 본 작업은 계속되어야 하므로 전부 삼킨다. 돌려준 ID 는 capture 의 ``generation_call_id`` 로 넘겨 **DB 호출 기록과 포착 자산을 묶는다**. ``to_db=False`` — 이미 자기 자리에서 ``log_llm_call`` 을 부르는 호출자용 (Opik 만 보탠다). 두 번 세지 않기 위한 것이다. ``output_text`` — 성공 기록의 산출 표시. ★기본값을 이미지로 두지 않는다 (Codex 리뷰 2026-08-07): 전에는 모든 성공에 ``"[image generated]"`` 를 박아서 **검색 호출까지 DB 에서 이미지 생성으로 읽혔다.** 이미지 호출자가 자기 표식을 넘긴다. ``provider`` — Opik span 의 provider. 모델 이름으로 못 가르는 경우 (검색 orchestrator 는 ``gpt-5.6`` 이라 이미지 규칙에 안 걸린다) 호출자가 명시한다. Nr) log_llm_callrcrrrrr) model_name user_promptrrGrIrroperation_type step_namereference_image_ids input_tokens output_tokens error_messagerku@record_provider_call: llm_call_log 기록 실패 (non-fatal): %s)rrb) rCrrDrErGrHrIrJrKrLrMrNu,record_provider_call: Opik 기록 실패: %s) app.modules.llm.llm_loggerrrnlistrr-r0r1get_image_tracerrrw)rCrrDrGrIrrrrErHrrrLrMrNcall_idrrrr5s rrecord_provider_callrswN"G )  ?" "+1Y+>KD'88L188L1(;HD$7d$kr..?${//0CD#+/::<D<41a&BBQ$<DLGK7GNJ1>$}-D#!*I>!  N=D  NNR   2 J CSII NJsBBC"C$ C"%5DC"" D +DD  D8D33D8)rLmodel_of prompt_ofrc.ddlfd}|S)u.litellm 을 우회하는 provider 호출 함수를 감싸 **성공·실패를 다** 남긴다. urllib 로 provider 를 직접 치는 자리(vision 검증·변형 추천·PDF 검증· legacy 구조화 출력)는 호출 흐름이 저마다 달라 본문 안에 기록을 심으면 빠뜨리기 쉽다. 감싸면 return 경로가 몇 개든 한 번만 남는다. ``model_of`` / ``prompt_of`` 는 감싼 함수의 인자에서 모델명·프롬프트를 꺼내는 함수다(사이트마다 인자 모양이 달라 호출자가 준다). rNcFjfd}|S)Nct}t |} rt |i|nd} rt |i|nd}t j }  |i|}t |||dtt j |z dz|   |S#t$rd}YwwxYw#t$rd}YrwxYw#t$rG}t |||dtt j |z dz| t|dd d}~wwxYw) Nrr rHrrZ) rCrrDrGrIrrrLrHrc) rCrrDrGrIrrrLr)rrrr-rrrr)argskwargsrrCrrDstartedresultr5fnrrrrrLs rwrapperz*traced_call..deco..wrapperVs/$&D$Y5D ":BHd5f56  .decoUs*      8r)r)rrLrrrrrs````` @r traced_callrBs"@ Kr_tracerct%t5t tadddtStS#1swYtSxYw)u+싱글턴 ImageTracer 반환 (thread-safe).N)r _tracer_lockrrUrrrr}s5 %- N7N Ns 2A)$rlogging threadingr contextlibrtypingrrrr getLoggerrr0r&r. ImportErrorrrrrrrrrrtrrrrrr__annotations__LockrrrUrrrs %,,   8 $ O    AAH,.14S>1h'# '#S#X'#3'#T DcN # #s(^834S>F#)-!%"&*"&!d d d  d  d  d sCx.dd}dDI&d C=d d#dsmd DcN #d !d"c]#dT# !% 33sm3 # 3n"&+ %y~~ +S  sD++D32D3