tPjo UddlZddlZddlmZddlmZddlmZmZddlm Z m Z erddl m Z dZ eed<Gd d e ZGd d e ZGd de ZGdde ZGdde ZdZeed<dZeed<dZeed<dZeed<Gdde ZGdde Ze eeZeed<e eed fZeed!<e eeZeed"<e eeZeed#<d$eed%efd&Z d'd(d)ed*ed+ee!d,ee!d%ef d-Z"y).N)Sequence)datetime) TYPE_CHECKINGFinal) BaseModel TypeAdapter) PrismaClientUnknownUNKNOWN_CALL_TYPEcJeZdZUeed<eed<eed<eed<eed<eed<y)CacheActivityGroup call_type api_requests cache_hitsfailed_requestscached_completion_tokensgenerated_completion_tokensN__name__ __module__ __qualname__str__annotations__intu/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/proxy/analytics_endpoints/cache_activity.pyr r s$NO!!!$$rr c@eZdZUeed<eed<eed<eed<eed<y)CacheActivityTotalsrrrrcache_hit_ratioN)rrrrrfloatrrrrrsO!!rrc.eZdZUeeed<eeed<y)CacheActivityFilterOptions key_aliasesmodelsN)rrrlistrrrrrr#r# sc Irr#c6eZdZUeed<eed<eed<eed<y)CacheActivityErrorBucketr error_code error_classcountNrrrrr(r(%sNO Jrr(cFeZdZUeeed<eed<eed<ee dfed<y)CacheActivityResponsegroupstotalsfilter_options.error_breakdownN) rrrr&r rrr#tupler(rrrr-r-,s+ # $$ ..3S899rr-aF SELECT CASE WHEN sl."call_type" = '' THEN 'Unknown' ELSE sl."call_type" END AS call_type, (COUNT(*) - SUM(CASE WHEN COALESCE(sl."cache_hit", '') = 'True' THEN 1 ELSE 0 END) - SUM(CASE WHEN sl."status" = 'failure' THEN 1 ELSE 0 END))::int AS api_requests, SUM(CASE WHEN COALESCE(sl."cache_hit", '') = 'True' THEN 1 ELSE 0 END)::int AS cache_hits, SUM(CASE WHEN sl."status" = 'failure' THEN 1 ELSE 0 END)::int AS failed_requests, SUM(CASE WHEN COALESCE(sl."cache_hit", '') = 'True' THEN sl."completion_tokens" ELSE 0 END)::int AS cached_completion_tokens, SUM(CASE WHEN COALESCE(sl."cache_hit", '') != 'True' THEN sl."completion_tokens" ELSE 0 END)::int AS generated_completion_tokens FROM "LiteLLM_SpendLogs" sl LEFT JOIN "LiteLLM_VerificationToken" vt ON sl."api_key" = vt."token" WHERE sl."startTime" >= ($1::timestamptz AT TIME ZONE 'UTC') AND sl."startTime" < (($2::timestamptz + INTERVAL '1 day') AT TIME ZONE 'UTC') AND ($3::jsonb = '[]'::jsonb OR COALESCE(vt."key_alias", 'Unnamed Key') IN (SELECT jsonb_array_elements_text($3::jsonb))) AND ($4::jsonb = '[]'::jsonb OR sl."model" IN (SELECT jsonb_array_elements_text($4::jsonb))) GROUP BY 1 ORDER BY (COUNT(*)) DESC GROUPS_SQLa SELECT CASE WHEN sl."call_type" = '' THEN 'Unknown' ELSE sl."call_type" END AS call_type, COALESCE(NULLIF(sl."metadata"->'error_information'->>'error_code', ''), 'Unknown') AS error_code, COALESCE(NULLIF(sl."metadata"->'error_information'->>'error_class', ''), 'Unknown') AS error_class, COUNT(*)::int AS count FROM "LiteLLM_SpendLogs" sl LEFT JOIN "LiteLLM_VerificationToken" vt ON sl."api_key" = vt."token" WHERE sl."status" = 'failure' AND sl."startTime" >= ($1::timestamptz AT TIME ZONE 'UTC') AND sl."startTime" < (($2::timestamptz + INTERVAL '1 day') AT TIME ZONE 'UTC') AND ($3::jsonb = '[]'::jsonb OR COALESCE(vt."key_alias", 'Unnamed Key') IN (SELECT jsonb_array_elements_text($3::jsonb))) AND ($4::jsonb = '[]'::jsonb OR sl."model" IN (SELECT jsonb_array_elements_text($4::jsonb))) GROUP BY 1, 2, 3 ORDER BY (COUNT(*)) DESC ERROR_BREAKDOWN_SQLad SELECT DISTINCT COALESCE(vt."key_alias", 'Unnamed Key') AS key_alias FROM "LiteLLM_SpendLogs" sl LEFT JOIN "LiteLLM_VerificationToken" vt ON sl."api_key" = vt."token" WHERE sl."startTime" >= ($1::timestamptz AT TIME ZONE 'UTC') AND sl."startTime" < (($2::timestamptz + INTERVAL '1 day') AT TIME ZONE 'UTC') ORDER BY 1 KEY_ALIAS_OPTIONS_SQLa SELECT DISTINCT sl."model" AS model FROM "LiteLLM_SpendLogs" sl WHERE sl."startTime" >= ($1::timestamptz AT TIME ZONE 'UTC') AND sl."startTime" < (($2::timestamptz + INTERVAL '1 day') AT TIME ZONE 'UTC') AND sl."model" != '' ORDER BY 1 MODEL_OPTIONS_SQLceZdZUeed<y) _KeyAliasRow key_aliasNrrrrrrrrr8r8usNrr8ceZdZUeed<y) _ModelRowmodelNr:rrrr<r<ys Jrr<_groups_adapter._error_buckets_adapter_key_alias_rows_adapter_model_rows_adapterr.returnc td|D}td|D}td|D}||z|z}t|||td|D|dkDr ||z dzSdS) Nc34K|]}|jywN)r.0groups r z!compute_totals..sEUe00Ec34K|]}|jywrE)rrFs rrIz!compute_totals..sAE,,ArJc34K|]}|jywrE)rrFs rrIz!compute_totals..s K5!6!6 KrJc34K|]}|jywrE)rrFs rrIz!compute_totals..s$XU%C%C$XrJrdg)rrrrr )sumr)r.rrr all_requestss rcompute_totalsrQsEfEELA&AAJ KF KKO&3oEL !'!$$XQW$X!X=IA=Ml2c9   TW  r prisma_clientr start_dateend_dater$r%c FKtjt|}tjt|}tj|j j t|||||j j t|||||j j t|||j j t||d{\}}} } tj|xsg} t| t| tt j| xsgD cgc]} | j"c} t$j| xsgD cgc]} | j&c} t(j|xsgS7cc} wcc} ww)N)r$r%)r.r/r0r1)jsondumpsr&asynciogatherdb query_rawr3r4r5r6r>validate_pythonr-rQr#r@r9rAr=r?) rRrSrTr$r%key_aliases_json models_json group_rows error_rowskey_alias_rows model_rowsr.rows rget_cache_activityrds[#jjk):;DL1K?F~~"":z8EUWbc""#6 HN^`kl""#8*hO""#4j(K @:6J NJ $33J4D"EF f%12I2Y2YZhZnln2op3p)<)L)LZM][])^_#CII_ />>z?ORP :q_s1CF!FAF!-FF!F0&F! F!)#rXrVcollections.abcrrtypingrrpydanticrrlitellm.proxy.utilsr r rr rr#r(r-r3r4r5r6r8r<r&r>r2r?r@rArQrrdrrrrisq $'+0$5$%%) y:I: E2U( u59 %T*<%=>> +E2JC2O,P QQ!,T,-?!@@(i9U9 8$67