Cj2KSrSSKrSSKrSSKrSSKJrJrJrJr SSK J r SSK J r SSK Jr SSKJr SSKJrJr SS KJrJrJr SS KJrJr SS KJrJr "S S \5rg)ao PostHog Integration - sends LLM analytics events to PostHog Follows PostHog's LLM Analytics format: https://posthog.com/docs/llm-analytics/manual-capture async_log_success_event: stores batch of events in memory and flushes to PostHog async_log_failure_event: logs failed LLM calls with error information For batching specific details see CustomBatchLogger class N)AnyDictOptionalTuple)verbose_logger)uuid)CustomBatchLogger) safe_dumps)should_use_posthog_mockcreate_mock_posthog_client)_get_httpx_clientget_async_httpx_clienthttpxSpecialProvider)POSTHOG_MAX_BATCH_SIZEPostHogEventPayload)StandardCallbackDynamicParamsStandardLoggingPayloadc ^\rSrSrU4SjrSrSrSrSSjrS\ \ \ 4S\ 4S jr S \S\ \ \ 4S \ S\ \ \ 44S jrS \ \ \ 4S\ \ \ 44SjrS \ \ \ 4S\ \ \ 44SjrS \S\ \ \ 4S\ 4SjrS\ \ \ 4S\\\ \\ 44SjrSrSrS\ \ \ 4S\ \ \ 44SjrS\ 4SjrS\S\ S\ \ \ 44SjrS S\ S\ S\ S\ 4SjjrSrSrU=r$)! PostHogLogger%c >[R"S5 [5UlUR(a [ 5 [R"S5 [ R "SS5c [S5e[[RS9Ul [5Ul [ R "S5Ul[ R "SS5nURS 5UlUR S 3UlS UlSUl/Ul[*R,"UR.5 [0TU]d"S0UDS[4S .D6 g![a)n[R6"S [9U535 UeSnAff=f)z Initializes the PostHog logger, checks if the correct env variables are set Required environment variables: `POSTHOG_API_KEY` - your PostHog API key `POSTHOG_API_URL` - your PostHog API URL (defaults to https://app.posthog.com) zPostHog: in init posthog loggerz6[POSTHOG MOCK] PostHog logger initialized in mock modePOSTHOG_API_KEYNz4POSTHOG_API_KEY is not set, set 'POSTHOG_API_KEY=<>') llm_providerPOSTHOG_API_URLzhttps://us.i.posthog.com//batch/F) flush_lock batch_sizez.PostHog: Got exception on init PostHog client )rdebugr is_mock_moder osgetenv ExceptionrrLoggingCallback async_clientr sync_clientrrstrip posthog_host capture_url_async_initializedr log_queueatexitregister_flush_on_exitsuper__init__r exceptionstr)selfkwargsposthog_api_urle __class__s n/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/litellm/integrations/posthog.pyr1PostHogLogger.__init__&sQ&   !B C 7 9D   *,$$Lyy*D19 VWW 61AA!D  12D #%99->#?D  ii(9;UVO / 6 6s ;D "&"3"3!4GR>R=SS[\d\i\i[jk  $$%TU$$%LM M  $ $'B3q6(%K L L MsDD! D!! E+"EEc# [R"SU5 UR5 URXX45IShvN gN![a,n[R "S[ U535 SnAgSnAff=f7fNz=PostHog: Async logging - Enters logging function for model %szPostHog Layer Error - rr _ensure_async_setup_log_async_eventr$r2r3r4r5rLrMrNr7s r9async_log_success_event%PostHogLogger.async_log_success_event|n   OQW   $ $ &''jS S S   $ $'=c!fX%F G  @B"A94B9A>>Bc# [R"SU5 UR5 URXX45IShvN gN![a,n[R "S[ U535 SnAgSnAff=f7frWrXr[s r9async_log_failure_event%PostHogLogger.async_log_failure_eventr^r_cT# URU5upVURU5nURRXuUS.5 [R "SUR S35 [UR5UR:aUR5IShvN ggN7f)N)eventrOrPz-PostHog, event added to queue. Will flush in z seconds...) rErFr,appendrr flush_intervallenr flush_queue)r4r5rLrMrNrOrPrQs r9rZPostHogLogger._log_async_events <" >>"9:F  &.{ # ) )~~&=zJH#3;/0*. #_a* %& ) ).2nn')P  $/<+ ,$(NN #_c% =! >>18 < I)-J~ &'> LI$*3;' "":6 ,,Z@ryrrcJURUS05nURUSUR55nXAS'URUSUR55nXQS'URU5nURS5=(d URS5nU(aXqS'gg) Nrltrace_idz $ai_trace_ididz $ai_span_id parent_run_id parent_idz $ai_parent_id)r _safe_uuid_extract_metadatart)r4rrr5rlrspan_idmetadatars r9r#PostHogLogger._add_trace_propertiess"&..9RTV"W>> #Z1B &.>"..!8$@QR$+=!))&1LL1NX\\+5N *3 ' rycURU5n[U[5(dg1SknUR5HupVXT;dM XaU'M g)z0Add custom metadata fields to PostHog propertiesN> rAuser_idapi_baseendpointr deployment model_info model_group user_api_key hidden_paramsrcaching_groupsmodel_group_sizeuser_api_key_hashuser_api_key_aliasuser_api_key_spendlitellm_api_versionuser_api_key_org_idrequester_ip_addressuser_api_key_team_iduser_api_key_user_iduser_api_key_metadatauser_api_key_max_budgetuser_api_key_team_aliasuser_api_key_team_spenduser_api_key_user_emaillitellm_parent_otel_spanuser_api_key_end_user_idglobal_max_parallel_requestsuser_api_end_user_max_budgetuser_api_key_team_max_budgetuser_api_key_model_max_budget)r isinstancedictitems)r4rrr5rlitellm_internal_fieldskeyvalues r9r-PostHogLogger._add_custom_metadata_propertiessO))&1(D)) "# H#..*JC1"'3+rycURU5nURUS5nU(a [U5$URUS5nU(a [U5$URUS5nU(a [U5$UR5$)Nrend_userr)rrr3r)r4rlr5rrrrs r9rwPostHogLogger._get_distinct_idAsz))&1..95 w< >>"9:F x= >>"9:F x=   rycURSS5nUbKURS5=(d URnURS5=(d URnX44$URnURnX44$)a0 Get PostHog credentials for this request. Checks for per-request credentials in standard_callback_dynamic_params, falls back to instance defaults from environment variables. Args: kwargs: Request kwargs containing standard_callback_dynamic_params Returns: tuple[str, str]: (api_key, api_url) standard_callback_dynamic_paramsNposthog_api_keyr6)rtrr))r4r5rrOrPs r9rE*PostHogLogger._get_credentials_for_requestQs JJ94 @ ) , 70445FG(''  1445FG%$$ **G''Gryc# UR(dg[R"S[UR5S35 UR(a[R"S5 0nURH,nUSUS4nX1;a/X'XR US5 M. UR 5HuupEnSS 0nURXd5nURS 5S 3n URRU [U5US 9IShvN n U R5 U RS :wdM[SU RSU R35e UR(a.[R"S[UR5S35 g[R"S[UR5S35 gN![a,n [R "S[#U 535 Sn A gSn A ff=f7f)z~ Sends the in memory logs queue to PostHog API Raises: Raises a NON Blocking verbose_logger.exception if an error occurs NzPostHog: Sending batch of z eventsz@[POSTHOG MOCK] Mock mode enabled - API calls will be interceptedrOrPrdr<r=rrr>rBrCrDz[POSTHOG MOCK] Batch of z events successfully mockedzPostHog: Batch of z events successfully sentz"PostHog Error sending batch API - )r,rr rgr!rerrGr(r&rHr rIrJr$rKr2r3 r4batches_by_credentialsitemrrOrPeventsrArRr*rSr7s r9async_send_batchPostHogLogger.async_send_batchss3 T>>  ,S-@,AI   $$V CE "IY8424*/&+224=A '/E.J.J.L*"F"$666vG!(!4 5W= !%!2!2!7!7#&w/#"8" ))+''3.#A(BVBVAWW_`h`m`m_no!/M(  $$.s4>>/B.CC^_$$(T^^)<(==VW#( T  $ $'I#a&%R S S Ts^HG HC:G G "G 7A%G H-G H G H"G>9H>HHcJUR(d][R"5Ul[R"UR 55 SUl[ R"S5 gg![a(n[ R"S[U535 eSnAff=f)NTz%PostHog: Async components initializedz0PostHog: Failed to initialize async components: ) r+asyncioLockr create_taskperiodic_flushrr r$errorr3)r4r7s r9rY!PostHogLogger._ensure_async_setups&& "),,.##D$7$7$9:*.'$$%LM '  $$Fs1vhO  sAA00 B":#BB"cnURS05=(d 0nURS05=(d 0$)Nlitellm_paramsr)rt)r4r5rs r9rPostHogLogger._extract_metadatas0$4b9?R!!*b17R7ryc>[[R"55$N)r3ruuid4)r4s r9rPostHogLogger._safe_uuids4::<  ryrrOc X!S.$)N)rObatchr)r4rrOs r9rG%PostHogLogger._create_posthog_payloads "44ryobjrdefaultcPUb[US5(dU$URX#5$)Nrt)hasattrrt)r4rrrs r9rPostHogLogger._safe_gets' ;gc511Nwws$$rycUR(dg[R"S[UR5S35 0nURH,nUSUS4nX1;a/X'XR US5 M. UR 5HuupEnSS0nUR Xd5nURS 5S 3n URRU [U5US 9n U R5 U RS :wdMw[R"S U R35 M UR(a.[R"S[UR5S35 O-[R"S[UR5S35 URR5 g![ a,n [R"S[#U 535 Sn A gSn A ff=f)ai Flush remaining events from internal log_queue before process exit. Called automatically via atexit handler. This works in conjunction with GLOBAL_LOGGING_WORKER's atexit handler: 1. GLOBAL_LOGGING_WORKER atexit invokes pending callbacks 2. Callbacks add events to this logger's internal log_queue 3. This atexit handler flushes the internal queue to PostHog NzPostHog: Flushing z remaining events on exitrOrPrdr<r=rrr>rBz*PostHog: Failed to flush on exit - status z$[POSTHOG MOCK] Successfully flushed z events on exitzPostHog: Successfully flushed z(PostHog: Error flushing events on exit: )r,rr rgrerrGr(r'rHr rIrJrr!clearr$r3rs r9r/PostHogLogger._flush_on_exits~~  T^^!4 55N O ) VBD "IY8424*/&+224=A '/E.J.J.L*"F"$666vG!(!4 5W= ++00#&w/#1 ))+''3."((DXEYEYDZ[!/M(  $$:3t~~;N:O_$$4S5H4IY NN " V  #KCPQF8!T U U Vs CF4B-F44 G*>"G%%G*) rr+r&r*rr!r,r)r')Nrrr) __name__ __module__ __qualname____firstlineno__r1rTr\rarZrr3rrrFrrvrrrwrrrErrYrrlistrGrr/__static_attributes__ __classcell__)r8s@r9rr%s.`$ML  CF%$! 38n! ! F8!78S#X8 8 c3h 8t4S#X4SRUX4 .(sCx..(26sCx..(`!'=!GKCQTH~! !  38n  x}hsm+ ,  D:Tx 8S#X84S>8!C!5d5S5T#s(^5%S%s%S%C% :V:Vryr)__doc__rr-r"typingrrrrlitellm._loggingr litellm._uuidr(litellm.integrations.custom_batch_loggerr *litellm.litellm_core_utils.safe_json_dumpsr (litellm.integrations.posthog_mock_clientr r &litellm.llms.custom_httpx.http_handlerr rr"litellm.types.integrations.posthogrrlitellm.types.utilsrrrrryr9rsR  --+FA V`V%`Vry