tPj "UddlZddlZddlZddlZddlmZmZdZeee d<defdZ de eeffdZ dededzfd Z dded edzd edzdedzfd Zd Zde eefde eeffdZdee eefdeee eefee eefffdZy)N)AnyFinalz~/.opik.configCONFIG_FILE_PATH_DEFAULTreturnc2ttjdz}ttjd}|j dd|ddd|ddzz|d<d |d d zz|d <t tjt| S) aGenerate an RFC 9562 conformant UUIDv7 string. The top 48 bits encode the Unix timestamp in milliseconds. Opik's backend validates this embedded timestamp on ingestion (it must fall within a window around "now"), so the encoding has to be correct or trace/span batches are rejected with HTTP 400. Implemented with the standard library only, so no extra dependency is added to litellm. See ``opik.id_helpers`` for the reference implementation. ibig) byteorderrp?)bytes) inttime bytearrayosurandomto_bytesstruuidUUIDr) unix_ts_ms uuid_bytess d/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/integrations/opik/utils.py create_uuid7r sDIIK$./J""**R.1J!))!u)=JqOJqMD01JqMJqMD01JqM tyyuZ01 22c tjjt}t j }|j ||jDcic]}|t|j|}}d|vr|dSiScc}w)Nopik) rpath expanduserr configparser ConfigParserreadsectionsdictitems) config_pathconfigsection config_valuess r_read_opik_config_filer.&s~++,DEK --/F KK PVP_P_PabWGT&,,w*?%@@bMb V$$ I cs"B keycTd}tj||zjdS)Nopik_)rgetenvupper)r/ env_prefixs r_get_env_variabler54s&J 99j3&--/ 66r user_value default_valuecR||St|}||St}||vr||S|S)z Get the configuration value of a variable, order priority is: 1. user provided value 2. environment variable 3. Opik configuration file 4. default value )r5r.)r/r6r7 env_valuer-s rget_opik_config_variabler:9sM)-I23M mS!! rci}|j|j|d<|j|j|d<|j|j|d<|S)Ncompletion_tokens prompt_tokens total_tokens)r<r=r>)usage usage_dicts rcreate_usage_objectrATsbJ **/*A*A &' &&+&9&9 ?# %%*%7%7 >" rxc\|jDcic] \}}| || c}}Scc}}w)zRemove None values from dict.)r))rBkvs r _remove_nullsrF`s(WWY 8TQ!-AqD 88 8s ((payloadc|Dcgc]}d|vst|}}|Dcgc]}d|vst|}}||fScc}wcc}w)aL Separate traces and spans from payload. Traces are identified by not having a "type" field. Spans are identified by having a "type" field. Args: payload: List of dicts containing trace and span data Returns: Tuple of (traces, spans) where both are lists of dicts with null values removed type)rF)rGrBtracesspanss r!get_traces_and_spans_from_payloadrLesS07J!&/]1%JFJ.5E1M!$EEE 5=KEs ? ? A A)NN)r$rrrtypingrrrr__annotations__rr(r.r5r:rArFlisttuplerLrrrRs '7%*73c38 S#X 7373:7 #3:UX[_U_knquku6 9T#s(^9S#X9  $sCx. ! 4S#X d38n!5 56r