MiJSSKrSSKrSSKrSSKrSSKrSSKJr SSKJrJr SSK J r J r J r J r SSKrSSKJr SSKrSSKJr SSKJr SSKJrJr SS K7 SS KJrJr S r"S S \5rg)N)uuid)datetimetimezone)AnyDictListOptional) BaseModel)verbose_logger)CustomBatchLogger)get_async_httpx_clienthttpxSpecialProvider)*)StandardCallbackDynamicParamsStandardLoggingPayloadc[R[R[R[4n[ X5(+$)N)types CoroutineType FunctionType GeneratorTyper isinstance)valuenon_serializable_typess x/var/www/eduai.edurigo.com/storigo/production/storigo_env/lib/python3.13/site-packages/litellm/integrations/langsmith.pyis_serializablers8     %8 88c ^^\rSrSrSS\\S\\S\\S\\4U4SjjjrSS\\S\\S\\S\4Sjjr S \4S jr S r S r S r SrS S\S\S\S\4SjjrS \S\\4SjrS\\\44SjrS\\\4S\4SjrS\\\4S\4SjrSrSrS\4SjrSrU=r$)!LangsmithLogger$langsmith_api_keylangsmith_projectlangsmith_base_urllangsmith_sampling_ratec >[R"5Ul[TU]"S 0UDSUR0D6 UR UUUS9Ul[R"S5b_[R"S5R5R5(a(U=(d [[R"S55OSUl [R"SS5Ul [[R S9Ul[R"SS5=(d [$R&nU(a[)U5Ul/Ul[R."UR155 g) N flush_lockr r!r"LANGSMITH_SAMPLING_RATEg?LANGSMITH_DEFAULT_RUN_NAMELLMRun) llm_providerLANGSMITH_BATCH_SIZE)asyncioLockr%super__init__get_credentials_from_envdefault_credentialsosgetenvstripisdigitfloat sampling_ratelangsmith_default_run_namer rLoggingCallbackasync_httpx_clientlitellmlangsmith_batch_sizeint batch_size log_queue create_taskperiodic_flush)selfr r!r"r#kwargs _batch_size __class__s rr0LangsmithLogger.__init__%s+",,. >6>doo>#'#@#@//1$A$  yy23? 34::<DDFF $ ;RYY89: +-)) ((+ '#9-==#  II,d 3 Sw7S7S  !+.DO57D//12rreturncU=(d [R"S5nU=(d [R"S5=(d SnU=(d [R"S5=(d Sn[UUUS9$)NLANGSMITH_API_KEYLANGSMITH_PROJECTzlitellm-completionLANGSMITH_BASE_URLzhttps://api.smith.langchain.com)rJrLrK)r3r4LangsmithCredentialsObject)rCr r!r"_credentials_api_key_credentials_project_credentials_base_urls rr1(LangsmithLogger.get_credentials_from_envJsr 1RBII>Q4R  W+>!? WCW   1yy-. 10  *242  r credentialsc URS05=(d 0nURS05=(d 0nURSUS5nURSUR5n URSURSS55n URSS5n URS S5n URS S5n URS S5n[R"S US U 35 URSS5nUc [ S5eUSnU SUUSUUSUSUSUS. nUSbUSS:XaUSUS'U (aU US'U (aU US'U (aU US 'U (aU US 'U(aUUS 'URS5n SU;dUSc$[ [ R"55n U US'S U;dUS cU b[U [ 5(aU US 'S U;dUS c*U b'[U [ 5(aURU S9US '[R"SU5 U$![a ef=f)Nlitellm_paramsmetadata project_namerKrun_nameidrun_id parent_run_idtrace_id session_id dotted_orderz"Langsmith Logging - project_name: z , run_name standard_logging_objectz,Error logging request payload. Payload=none.llmresponse startTimeendTime request_tags) namerun_typeinputsoutputs session_name start_timeend_timetagsextra error_strstatusfailureerror)rYz'Langsmith Logging data on langsmith: %s) getr9r debug Exceptionstrruuid4rmake_dot_order)rCrD response_objrirjrR_litellm_paramsrUrVrWrYrZr[r\r]payloaddatas r_prepare_log_data!LangsmithLogger._prepare_log_data`sU $jj)92>D"O&**:r:@bH#<< ,? @L ||J0O0OPH\\$ Xt(DEF$LL$?M||J5H!lD9J#<<=L  4\N+hZX  9? )49G NOOH !!!":. ,%k2#I./! D{#/GH4E4R ' 4W #T (5_%#+Z %/\"'3^$$(HHTNF44:#5TZZ\*#T $& #+'Jvs,C,C#)Z d*'/'Jvs,C,C'+':':&':'I^$  !JD QK   s H5H88 IcZURUS9n[R"5nXe:a&[R"SR XV55 g[R "SUU5 UR US9nURUUUUUS9nURR[UUS95 [R "SURS35 [UR5UR:aUR5 gg![a [R "S5 gf=f) NrD>Skipping Langsmith logging. Sampling rate={}, random_sample={}z;Langsmith Sync Layer Logging - kwargs: %s, response_obj: %srDrwrirjrRrzrRz/Langsmith, event added to queue. Will flush in z seconds...z/Langsmith Layer Error - log_success_event error)%_get_sampling_rate_to_use_for_requestrandomr infoformatrr#_get_credentials_to_use_for_requestr{r@appendLangsmithQueueObjectflush_intervallenr? _send_batchrs exception rCrDrwrirjr8 random_samplerRrzs rlog_success_event!LangsmithLogger.log_success_events0& X FFfFUM"MMOM,##T[[%   M  BB&BQK)))%!' *D NN ! !$ +   A$BUBUAVVab 4>>"doo5  "6 X  $ $%V W XsADB4D D*)D*c# URUS9n[R"5nXe:a&[R"SR XV55 g[R "SUU5 UR US9nURUUUUUS9nURR[UUS95 [R "S[UR5UR5 [UR5UR:aUR5IShvN ggN![a [R"S5 gf=f7f)Nr~rz>"doo5&&(((6(   $ $L  sHE AD$E CD$D"D$ E "D$$ EE EE c# URUS9n[R"5nXe:a&[R"SR XV55 g[R"S5 UR US9nUR UUUUUS9nURR[UUS95 [R"S[UR5UR5 [UR5UR:aUR5IShvN ggN![a [R"S5 gf=f7f)Nr~rz Langsmith Failure Event Logging!rrrz:Langsmith Layer Error - error logging async failure event.)rrr rrrr{r@rrrrrr?rrsrrs rasync_log_failure_event'LangsmithLogger.async_log_failure_events0BB&BQ    (   PWW!  >? BB&BQK)))%!' *D NN ! !$ +   CDNN#  4>>"doo5&&(((6(   $ $L  s=A&E)B0D"D D"E D"" EEEEc# UR(dgUR5nUR5H/nURURUR S9IShvN M1 gN 7f)a Handles sending batches of runs to Langsmith self.log_queue contains LangsmithQueueObjects Each LangsmithQueueObject has the following: - "credentials" - credentials to use for the request (langsmith_api_key, langsmith_project, langsmith_base_url) - "data" - data to log on to langsmith for the request This function - groups the queue objects by credentials - loops through each unique credentials and sends batches to Langsmith This was added to support key/team based logging on langsmith NrR queue_objects)r@_group_batches_by_credentialsvalues_log_batch_on_langsmithrRr)rC batch_groups batch_groups rasync_send_batch LangsmithLogger.async_send_batch8sf"~~ 99; '..0K..'33)77/  1 sAA+A) A+urlendpoint api_versionc|X1;aURS5U3nURS5(aUU3$USU3$)N/)rstripendswith)rCrrrs r_add_endpoint_to_url$LangsmithLogger._add_endpoint_to_urlSsP  !ZZ_%k]3C <<  U8*% %az""rrcB# USnUSnURUS5nSU0nUVs/sHowSPM nn[R"S[U55 URR USU0US9IS hvN n U R 5 U RS :a1[R"S U RS U R35 g [R"S [UR5S35 g s snfN![RaNn [R"SU RRS U RR35 S n A g S n A f[a/ [R"S[ R""535 g f=f7f)a Logs a batch of runs to Langsmith sends runs to /batch endpoint for the given credentials Args: credentials: LangsmithCredentialsObject queue_objects: List[LangsmithQueueObject] Returns: None Raises: Does not raise an exception, will only verbose_logger.exception() rLrJz runs/batch x-api-keyrzz%Sending batch of %s runs to Langsmithpost)rjsonheadersNi,zLangsmith Error: z - z Batch of z runs successfully createdzLangsmith HTTP Error: zLangsmith Layer Error - )rr rrrr;rraise_for_status status_coderptextr@httpxHTTPStatusErrorrr`rs traceback format_exc) rCrRrlangsmith_api_baser rr queue_objectelements_to_logr`es rr'LangsmithLogger._log_batch_on_langsmith]s"))=>'(;<''(:LI 12DQRML/MR   7_9M "4499o.:H  % % '##s*$$'(<(<'=SP$$DNN 344NO%S $$   $ $()?)?(@AJJOOCTU     $ $*9+?+?+A*BC  se%FC<FAD8D9AD F-D;FDFAE F 9FFFFc0nURHvnUSnUSbUSc [R"SUSUS5 M4[USUSUSS9nXA;a [ U/S9X'XR R U5 Mx U$)z@Groups queue objects by credentials using a proper key structurerRrJrKzBLangsmith Logging - credentials missing - api_key: %s, project: %srL)api_keyprojectbase_urlr)r@r warningCredentialsKey BatchGrouprr)rClog_queue_by_credentialsrrRkeys rr-LangsmithLogger._group_batches_by_credentialssEG  NNL&}5K/0823;&&X 34 34  #$78#$78$%9:C 20: +21(- % ) 7 7 > >| L1+4('rrDcURSS5nURnUbURS5nUb [U5nU$)N standard_callback_dynamic_paramsr#)rqr8r7)rCrDrr8_sampling_rates rr5LangsmithLogger._get_sampling_rate_to_use_for_requestsT JJ94 @ ) $11 + 7=AA)N) %n 5 rcURSS5nUbCURURSS5URSS5URSS5S9nU$URnU$)z Handles key/team based logging If standard_callback_dynamic_params are provided, use those credentials. Otherwise, use the default credentials. rNr r!r"r&)rqr1r2)rCrDrrRs rr3LangsmithLogger._get_credentials_to_use_for_requests JJ94 @ ) , 777"B"F"F'##C"F"F'#$D#G#G($$8 K22KrcnUR(dg[R"5nUR5(a%[R"UR 55 gUR UR 55 g![a' [R"UR 55 gf=f)z'Calls async_send_batch in an event loopN) r@r-get_event_loop is_runningrArrun_until_complete RuntimeErrorrun)rCloops rrLangsmithLogger._send_batchs~~  1))+D  ##D$9$9$;<''(=(=(?@ 1 KK--/ 0 1sAB#B.B43B4cURSnURSnUSU3n[RRUSU0S9nUR 5$)NrJrLz/runs/r)rr)r2r<module_level_clientrqr)rCrYr rrr`s r get_run_by_idLangsmithLogger.get_run_by_idsl 445HI!556JK#$F6(3..22 "343  }}rrYc[R"[R5nUnUR S5[ U5-$)Nz%Y%m%dT%H%M%S%fZ)rnowrutcstrftimert)rCrYstid_s rrvLangsmithLogger.make_dot_orders2 \\(,, '{{-.S99r)r;r?r2r%r9r@r8)NNNN)NNN)z/api/v1)__name__ __module__ __qualname____firstlineno__r rtr7r0rMr1r{rrrrrrrrrrrrrrrrrrv__static_attributes__ __classcell__)rFs@rrr$sq,0+/,037 #3#C=#3$C=#3%SM #3 "*% #3#3N,0+/,0  #C= $C= %SM  $  ,] 0 ]~'XR(T$L8;D##"%#47# #1/1011f(tNJ4N/O(@ DcN u 38n #:1$ :S::rr)r-r3rrr litellm._uuidrrrtypingrrrr rpydanticr r<litellm._loggingr (litellm.integrations.custom_batch_loggerr &litellm.llms.custom_httpx.http_handlerr r$litellm.types.integrations.langsmithlitellm.types.utilsrrrrr,rrrsR  ',, +F3U9X:'X:r