j'\dZddlZddlZddlZddlZddlmZmZm Z m Z eje Z dZ d dedededed ed ed e eeeffd Z d dededed ed ed e eeeff d Zdeeefd e efdZdeeefd efdZdeeefdeeeeeffd efdZehdZdeeefd efdZd efdZde eeefdeeeeeffd e eeeffdZ d dededed ed ed e eeeff dZ d dddededed ed eded eeeeefffdZdeeefd eeeffdZy)!uIOpik REST 에서 trace 를 시간 창으로 걷어온다 (읽기 전용).N)AnyDictListOptionalkindbase_url workspace project_namesinceuntilreturnc g}d} tjj|t|t j dddgd}tj j|d|d|d |i } tj j| d 5} t j| j} d d d  jdg} | snjd} | D]4}|jdd}||krd} n||ks$|j|6| s%|tzt| jddk\rn|dz }6tjd|t!|||S#1swYxYw)u `traces`/`spans` 공통 페이지 순회 — 기간 자르기 규칙은 하나뿐이다. start_time 이 [since, until) 인 행 전부 (최신순 페이지 순회). base_url 예: http://192.168.133.87:5173/api since/until: ISO 문자열 비교 (Opik start_time 은 ISO·UTC — 문자열 비교가 시간 순서와 일치한다). ★**여기서 거르지 않는다.** 시험 기록 판별은 span 과 부모 trace 를 **함께 봐야** 하므로(`select_call_rows`) 이 함수는 raw 로 준다. T start_timeDESC)field direction)r sizepagesortingz /v1/private/?zComet-Workspace)headers<)timeoutNcontentFtotalru%s %d건 수집 (since=%s))urllibparse urlencode PAGE_SIZEjsondumpsrequestRequesturlopenloadsreadgetappendintloggerinfolen)rr r r r r tracesrqreqrdrstoptsts Q/Users/manta/Documents/Projects/TheRoad-I1/tools/opik_prompt_audit/audit/fetch.py _fetch_pagedr9 sf$$&F D  LL " "(zz'f=>@ $  nn$$j TF!A3 /& 2%4^^ # #C # 4 1668$A5%% 2& A|R(BEzEz a  4)#s155!+<'==   5 6 KK,dCKG M#5 4s $EE(c"td|||||S)u6v1 호환 — 기존 소비처가 이것을 부른다.r0r9r r r r r s r8 fetch_tracesr=@s (I|u &&rowc|jdxsgD]4}t|ts|jds&|t ddcSy)uH`step:` 축 태그만 — 없으면 None. 이름으로 안 떨어진다.tagszstep:N)r* isinstancestr startswithr/)r?tags r8 _step_tagrFLsG%2% c3 CNN7$;s7|}% %& r>tracec`t|}|r|S|jdxsi}t|tr|jdnd}t|tr&d|vr"|j ddj St|tr|r|St |jdxsdS)utrace/span 의 스텝 이름. 1순위 = `step:` 축 태그(v2). 2순위 = litellm 메타의 `trace_name` 마지막 조각(v1 — 지난 자료를 계속 읽기 위해). 3순위 = 이름. metadata trace_nameN>namer)rFr*rBdictrCsplitstrip)rGrEmdtns r8step_ofrSTs E C  :  $"B!+B!5 4B"csbyxx}R &&(("cr uyy 'C ((r>span trace_indexct|}|r|S|jt|jd}|#t|}|r|St|}|r|dk7r|St|S)u호출(span) 하나의 스텝 이름. ① 자기 `step:` 태그 (v2) ② 부모 trace 의 스텝 (v1 — `{step}/{model}` 이름이나 `metadata.trace_name`) ③ 그래도 없으면 span 이름 ★②를 ③보다 먼저 본다. `step_of` 를 먼저 부르면 span 이름으로 떨어져 부모를 영영 안 본다 — litellm span 이름(`{model}_{obj}_{created}`)은 **절대 비지 않기** 때문이다. trace_idr)rFr*rCrS)rTrUrEparentptagpnames r8 step_of_callr[fsj D/C  __S*!56 7F   K Uc\L 4=r>>p-i2iproj-1pp1testc|jdxsi}t|tsy|jd}t|tr |tvryd|vsd|vry|jddk(xr| S)uP시험이 남긴 기록인가 — 감사 셈에서 뺀다. 2026-08-23 이전에는 돈 가드가 집 안 주소를 통과시켜 시험이 프로덕션 프로젝트에 썼다. 지우지 않고 여기서 거른다 — 지우는 것은 되돌릴 수 없다. ★**이 그물은 완전하지 않다.** 두 갈래로 잡는다: 1. 신원 없이 시간 0 — `record_provider_call` 을 scope 밖에서 부른 시험 2. **가짜 신원** — `generation_context("p-i2i", …)` 안에서 부르면 `project_id="p-i2i"` 가 실려 1번 그물을 **통과한다** 그래도 못 잡는 것이 남는다(litellm 경로를 타는 시험 등). 그래서 리포트에 **「걸러진 수」와 함께 「이 그물이 못 잡는 모양」**을 같이 적는다 — 「0 건」이 「없다」로 읽히면 안 된다. rIF project_idTstep duration_msr)r*rBrNrC_TEST_PROJECT_IDS)r?rQpids r8is_test_originrgst   "B b$  && C#s'8 8 R=2 66- A % 1c'1r>cy)uI리포트에 함께 실을 한 줄 — 이 그물의 한계를 밝힌다.u★시험 기록 필터는 완전하지 않다 — 가짜 신원 목록에 없는 값이나 litellm 경로를 탄 시험 기록은 통과한다. 「걸러진 수」를 「오염 총량」으로 읽지 말 것.rir>r8test_filter_caveatrjs 8r>spanscg}|D]V}t|r|jt|jd}| t|rF|j|X|S)u 감사 대상 span 만 고른다 — **자기 또는 부모가 시험이면 뺀다**. span metadata 에는 `step` 이 없어서(`image_tracer` 가 trace 에만 넣는다) span 만 보면 시험 판별이 안 된다. 부모 trace 에는 있다. **둘을 함께 본다.** 안 그러면 부모만 지워지고 자식 span 이 새 감사 SOT 에 그대로 들어가 「시험 기록 0건」이 거짓 통과한다. ★부모를 못 찾은 span 은 **버리지 않는다** — 못 찾은 것과 시험인 것은 다르다. rW)rgr*rCr+)rkrUoutsprXs r8select_call_rowsros\!#C "  RVVJ%7!89  ."8  2  Jr>c"td|||||S)u3감사 대상 = **호출 하나당 한 행**. 그것은 언제나 span 이다. (raw) ★span 과 trace 를 그냥 합치면 **지난 자료를 두 번 센다.** `ImageTracer.log` 는 호출 하나마다 trace 를 만들고 그 밑에 span 도 만든다. litellm 도 `trace_id` 가 없으면 trace 를 만들고 span 은 **항상** 만든다. 즉 v1 호출 한 건이 **trace 1 + span 1** 로 남아 있다. 두 배가 된 숫자로는 「팩이 얼마나 커졌나」를 못 묻는다 — 이 도구의 존재 이유가 사라진다. 그래서 **세는 것은 언제나 span** 이고 trace 는 묶음·이름을 얻는 데만 쓴다(`fetch_trace_index`). ★인자·기간 계약은 `fetch_traces` 와 **같게** 둔다. 다르면 소비처가 조용히 전 기간을 센다. rkr;r<s r8 fetch_spansrqs* 9lu &&r>) pad_hoursrsc:ddl} |jj|jdd}||j|z j }t d|||||D cic]} | jdr| d| c} S#t $r|}Y@wxYwcc} w)ul`trace_id` → trace. **세는 데는 안 쓴다** — 묶음·이름·시험 판별용. ★창을 `pad_hours` 만큼 **앞으로 넓힌다.** 창 경계 직전에 시작한 긴 trace 의 창 안 span 이 부모를 잃으면, 시험 판별도 legacy 스텝 fallback 도 함께 깨진다. 부모를 못 찾는 것이 여기서는 가장 나쁘다. rNZz+00:00)hoursr0id)datetime fromisoformatreplace timedelta isoformat ValueErrorr9r*) r r r r r rs_dt_swider6s r8fetch_trace_indexrs \\ ' ' c8(D ES]]]33>>@!-(I|T5!B !B1 55; dGQJ!B   sAB&B BBcddd}|jd}t|tru|D]n}t|ts|jd}||vr*|jd}||xxt|tr|nt j |dz cc<p|St|tr&|jd}t|tr||d <|S) uinput 에서 role 별 텍스트 결합 (system/user). 비텍스트 파트는 JSON 직렬화 길이로만 세지 않고 문자열화해 포함한다.r)systemuserinputrolerF) ensure_asciipromptr)r*rBlistrNrCr#r$)rGrminpmrcr^s r8 messages_ofrs $C ))G C#tAa&55=D3i A IjC0djj7' 'I J C  GGH  a CK Jr>)9999)__doc__r#logging urllib.parserurllib.requesttypingrrrr getLogger__name__r-r"rCr9r=rFrSr[ frozensetreboolrgrjrorqr,rrrir>r8rsO ,,   8 $   0 000 0  0  0 $sCx.0p & & & &  &  &  $sCx. &4S>hsm)4S>)c)$tCH~"3S#X#67