)hSSKJr SSKJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK Jr SSKJrJr SSKJrJrJrJr SSKJr SSKJr SSKJr SS KJrJ r J!r!J"r" SS K#J$r$J%r%J&r& \(a SS K'J(r( SS K)J*r* \RV"S 5r,\RZ"\"5S-S9r.S Sjr/\R`"SS55r1S!S"Sjjr2S#S$Sjjr3S%Sjr4S&S'Sjjr5S&S(Sjjr6S)S*Sjjr7S+Sjr8S,Sjr9S-Sjr:S.Sjr;S/Sjr<S0S1Sjjr=S2Sjr>g)3) annotationsN) cpu_count)EmptyQueue) TYPE_CHECKINGOptionalUnioncast)schemas)utils)CompressedTraces)_AUTO_SCALE_DOWN_NEMPTY_TRIGGER_AUTO_SCALE_UP_NTHREADS_LIMIT_AUTO_SCALE_UP_QSIZE_TRIGGER _BOUNDARY)SerializedFeedbackOperationSerializedRunOperation#combine_serialized_queue_operations)Context)Clientzlangsmith.client max_workerscSSKJn U"[5nUH.nURUR4nX$R U5 M0 U$)z4Group batch items by (api_url, api_key) combination.r) defaultdict) collectionsrlistapi_urlapi_keyappend)batchrgroupeditemkeys V/root/34ku/venv/lib/python3.13/site-packages/langsmith/_internal/_background_thread.py_group_batch_by_api_endpointr&.sD($G||T\\* D! Nc\rSrSr%SrS\S'S\S'S\S'S\S 'S \S 'S rSSSjjrSSjrSSjr Sr g )TracingQueueItem;zAn item in the tracing queue. Attributes: priority (str): The priority of the item. item (Any): The item itself. otel_context (Optional[Context]): The OTEL context of the item. strpriority:Union[SerializedRunOperation, SerializedFeedbackOperation]r# Optional[str]rrOptional[Context] otel_contextr,r#rrr0Nc@XlX lX0lX@lXPlgNr1)selfr,r#rrr0s r%__init__TracingQueueItem.__init__Ms!    (r'cURURR4URURR4:$r3)r,r# __class__r4others r%__lt__TracingQueueItem.__lt__[s; tyy223 NN JJ 7   r'c[U[5=(aE URURR4URURR4:H$r3) isinstancer)r,r#r8r9s r%__eq__TracingQueueItem.__eq__asM%!124 MM II  8 nnejj22 384 4r')rrr#r0r,)NNN) r,r+r#r-rr.rr.r0r/returnNone)r:r)rAbool)r:objectrArC) __name__ __module__ __qualname____firstlineno____doc____annotations__ __slots__r5r;r?__static_attributes__r'r%r)r);sM DD  ##JI "&!%*. ) )I ) )  ) ( )  ) 4r'r)c/nSnURUSS9=n(a:URU5 US:a#XVRR5- nXS:aU$URUSS9nURU5 US:a$XVRR5- nXS:aU$U(a[ U5U:aU$Mg![a U$f=f![a U$f=f)Nrg?)blocktimeout皙?)getr r#calculate_serialized_sizerlen) tracing_queuelimitrOmax_size_bytes next_batch current_sizer#s r%_tracing_thread_drain_queuerZhs*,JL$ !$$5$$? ?4 ?   d #! C C EE 0%% $((ud(C   d #! C C EE  0  ZE1 - $ ' "    sHACCB?)8C$C=C? C  C C  C CCcURcgURR URRnUR=(d UnUbUS::a[ SU35eUbUS:a[ SU35eUbX2:a'UbURR U:a SSS5 gURR RS[S3R55 URR R5 URRR5nURRnURRUlX44nURR5 SSS5 WR!S5 UW4$!,(df  N#=f!["a [$R'SSS 9 gf=f) N)NNrz!size_limit must be positive; got z*size_limit_bytes must be nonnegative; got z--z-- uLangSmith tracing error: Failed to submit trace data. This does not affect your application's runtime. Error details:Texc_info)compressed_traceslockuncompressed_size_max_batch_size_bytes ValueError trace_countcompressor_writerwriterencodeclosebuffertell_contextcontextresetseek Exceptionloggererror)client size_limitsize_limit_bytespre_compressed_sizerY filled_buffercompressed_traces_infos r%'_tracing_thread_drain_compressed_bufferrxs/  # # +  % % * *"(":":"L"L %;;O?O %*/ #DZL!QRR+0@10D @AQ@RS !(,?,R"f&>&>&J&JZ&W!#+ *(  $ $ 6 6 < <YKv&--/   $ $ 6 6 < < >!33::??AL"44;;M$*$<$<$E$EM !&9%H "  $ $ * * ,?+B 1566E+ *F       s; F.F.BF&F./CFF. F+'F..GGc UVVs/sHup#UPM nnnUVs/sHoURS5PM nnURc [S5e[URU55n[ U5[ U5:wa#[ S[ U5S[ U535eUVs/sHoURS5PM nnX:wa[ SUSU35e[ X5H:uupn U S:XaURU 5 M!U S:XdM)URU 5 M< UR(aURR5 ggs snnfs snfs snf![a [RS S S 9 gf=f) z1Process a batch of run operations asynchronously.idNzAprocess_buffered_run_ops should not be None when processing batchzGprocess_buffered_run_ops must return the same number of runs. Expected z, got zKprocess_buffered_run_ops must preserve run IDs in the same order. Expected postpatchzLangSmith buffered run ops processing error: Failed to process batch. This does not affect your application's runtime. Error details:Tr])rR_process_buffered_run_ops RuntimeErrorrrTrczip _create_run _update_run_data_available_eventsetrorprq) rrbatch_to_process_run_data run_dictsrun original_idsprocessed_runs processed_ids operation processed_runs r%_process_buffered_run_ops_batchrs+ 1AB1A+!X1A B1:;#  ;  + + 3S f>>yIJ ~ #i. 0 N+6#n2E1FH  3AA.3. A  ((> @  .11A-R )NYMF"""=1g%""=1 .S  ' '  ( ( , , . (AC; B"       s@E!EE!EA3E!)EAE!AE!E!!FFc|[U5nUR5GHuupxn U(d&[U V s/sHoRPM sn 5n OHU V s1sHoRRiM n n UV s/sHoRU ;dMU PM n n U(aUR XUS9 M[ SU 55(a>[RS5 U V s/sHn [U [5(aMU PM n n UR[[[U 5UUS9 GM U(aUbUHnUR#5 M gggs sn fs sn fs sn fs sn f![a [R!SSS9 N[f=f![$a3nS['U5;a[R)S U35 SnAMeSnAff=f!U(a_Ub[UHTnUR#5 M![$a3nS['U5;a[R)S U35 SnAMMeSnAff=f fff=f) aHandle a batch of tracing queue items by sending them to LangSmith. Args: client: The LangSmith client to use for sending data. tracing_queue: The queue containing tracing items (used for task_done calls). batch: List of tracing queue items to process. use_multipart: Whether to use multipart endpoint for sending data. mark_task_done: Whether to mark queue tasks as done after processing. Set to False when called from parallel execution to avoid double counting. ops: Pre-combined serialized operations to use instead of combining from batch. If None, operations will be combined from the batch items. )rrc3B# UHn[U[5v M g7fr3)r>r).0ops r% /_tracing_thread_handle_batch..%sWYrz"&ABBYsz;Feedback operations are not supported in non-multipart moder\Tr]N!task_done() called too many times3Ignoring harmless task_done error during shutdown: )r&itemsrr#rz_multipart_ingest_opsanyrpwarningr>r_batch_ingest_run_opsr rrrorq task_donercr+debug)rrrUr! use_multipartmark_task_doneopsgrouped_batchesrr group_batchr# group_ops group_idsrres r%_tracing_thread_handle_batchrs8,56u=/>/D/D/F + W ?+67;4YY;7 7BBkdYY\\k B*-D#B)1CR# D,,-WYWWWNNU #,!"+B)".IJ"+! ,,45yA##-/0GJ m7 !++-8>E8CD!       ":c!fD QRSQTU m7 !++-!:c!fD QRSQTU8>s4E/E E/E 6E/<E%E%A E/$E*E*-E/FE//F GFG G'G  G  GH;$G64H;6 H3 'H. 'H;-H. .H3 3H;cUc%[UVs/sHoURPM sn5nUVs/sHn[U[5(dMUPM nnUVs0sHEn[UR[5(dM$URRUR _MG nnU(a>UR bUR RXx5 O[RS5 U(aUbUHn UR5 M gggs snfs snfs snf![a [RSSS9 NVf=f![a3n S[U 5;a[RSU 35 Sn A MeSn A ff=f!U(a_Ub[UHTn UR5 M![a3n S[U 5;a[RSU 35 Sn A MMeSn A ff=f fff=f)a@Handle a batch of tracing queue items by exporting them to OTEL. Args: client: The LangSmith client containing the OTEL exporter. tracing_queue: The queue containing tracing items (used for task_done calls). batch: List of tracing queue items to process. mark_task_done: Whether to mark queue tasks as done after processing. Set to False when called from parallel execution to avoid double counting. ops: Pre-combined serialized operations to use instead of combining from batch. If None, operations will be combined from the batch items. NzLangSmith tracing error: Failed to submit OTEL trace data. This does not affect your application's runtime. Error details: client.otel_exporter is NonezpOTEL tracing error: Failed to submit trace data. This does not affect your application's runtime. Error details:Tr]rr)rr#r>rrzr0 otel_exporter export_batchrprqrorrcr+r) rrrUr!rrr#rrun_opsotel_context_maprrs r%!_otel_tracing_thread_handle_batchrKs(( ;5U6SUTyyU6STC #N"z"6L'M2N $))%;< ,DIILL$++ +  ##/$$11'L B m7 !++-8>57TN        ":c!fD QRSQTU m7 !++-!:c!fD QRSQTU8>s D D D D DD #D>%D#1D FD :ED E>FEF F'E<;E<<FG,F'%G,' G$ 1'G G,G G$ $G,c 4[UVs/sHoURPM sn5n[R"U5n[R"U5n[R "SS9n U R [UUUUSU5n U R [UUUSU5n U R5 U R5 SSS5 U(aUbUHn UR5 M gggs snf!,(df  N:=f![aKn S[U 5;a6[RS5 [XX#SU5 [XUSU5 Sn A NeSn A ff=f![a3n S[U 5;a[RSU 35 Sn A MeSn A ff=f) aHandle a batch of tracing queue items by sending to both both LangSmith and OTEL. Args: client: The LangSmith client to use for sending data. tracing_queue: The queue containing tracing items (used for task_done calls). batch: List of tracing queue items to process. use_multipart: Whether to use multipart endpoint for LangSmith. mark_task_done: Whether to mark queue tasks as done after processing. Set to False primarily for testing when items weren't actually queued. rFNz6cannot schedule new futures after interpreter shutdownz@Interpreter shutting down, falling back to sequential processingrr)rr#copydeepcopycfThreadPoolExecutorsubmitrrresultr~r+rprrrc)rrrUr!rrr#r langsmith_opsotel_opsexecutorfuture_langsmith future_otelrrs r%#_hybrid_tracing_thread_handle_batchrs$ .U.KUTyyU.K LCMM#&M}}S!H'  " "q 1X',  #//1 K  # # %    -2P-3A '')4~a/L2 1.  Cs1v M LLR  )uUM  .ueX   * 6#a&@LLMaSQ saC,D'AC1=DE1 C?;D?D E AEEE F$'FFFc[US5(a URcg[R"S5(dgSSKJn UR 5n[US5(a[[URS5(a@URRRS S5n[RS U35 U$g![a#n[RS US 35 SnAgSnAff=f) zCheck if client is using LangSmith's internal OTLP provider. Returns True if using LangSmith's internal provider, False if user provided their own. rNF OTEL_ENABLEDr)traceresource attributeszlangsmith.internal_providerz;TracerProvider resource check: langsmith.internal_provider=z)Could not determine TracerProvider type: z, assuming user-provided) hasattrrls_utilsis_env_var_truish opentelemetryrget_tracer_providerrrrRrprro)rrrtracer_provider is_internalrs r% _is_using_internal_otlp_providerrs 6? + +v/C/C/K)).99 (335 ?J / /G  $ $l5 5 *22==AA-uK LL//:m=    7s:R S  sCBC C- C((C-c[R"S5nUb [U5$g![a [R SUS35 gf=f)NBATCH_INGEST_SIZE_LIMITz+Invalid value for BATCH_INGEST_SIZE_LIMIT: z, continuing with default)r get_env_varintrcrpr)size_limit_strs r%get_size_limit_from_envrsg))!N! ~& &    NN=n=MN**    s '#A  A c [R"SSS[[[S9nU(dU$UR (dU$[ 5nUbX R S'UR $![a Us$f=f)NFd)use_multipart_endpointrtrsscale_up_nthreads_limitscale_up_qsize_triggerscale_down_nempty_triggerrs) ls_schemasBatchIngestConfigrrrbatch_ingest_configr BaseException)infodefault_configenv_size_limits r%_ensure_ingest_configrs 11$ =;"A N ''! !02  %5C $ $\ 2''' sA*&A** A98A9c[R"S5n[R"S5nU(dgU(+nUnX#4$)aRGet the current tracing mode configuration. Returns: tuple[bool, bool]: - hybrid_otel_and_langsmith: True if both OTEL and LangSmith tracing are enabled, which is default behavior if OTEL_ENABLED is set to true and OTEL_ONLY is not set to true - is_otel_only: True if only OTEL tracing is enabled r OTEL_ONLY)FF)rr) otel_enabled otel_onlyhybrid_otel_and_langsmith is_otel_onlys r%get_tracing_moder)sB--n=L**;7I $- L $ 22r'c*^^^U"5mTcgTRnUce[TR5nUSnUSnUSnURSS5n/mSm[R "S5=(d TR SLnU(dU(aTRR=(d 0RSS5(d[RS 5 O[R"5Tl [5Tl[R "5Tl[R$"[&[R("T54S 9R+5 TS - mSUUU4S jjnU"5(Ga3TH+n U R-5(aMTR/U 5 M- [1T5U:adUR35U:aP[R$"[4[R("T5U4S 9n TR7U 5 U R+5 [95upTR:=(d URS 5=(d Sn [=XU S9=n(a6U (a[?TXU5 O!U (a [ATX5 O [CTXU5 U"5(aGM3[95upTR:=(d URS 5=(d Sn [=XSU S9=n(aU (a#[RES5 [?TXU5 OKU (a"[RES5 [ATX5 O"[RES5 [CTXU5 [=XSU S9=n(aM[RES5 g)NrsrrrFrDISABLE_RUN_COMPRESSIONzstd_compression_enabledz~Run compression is not enabled. Please update to the latest version of LangSmith. Falling back to regular multipart ingestion.)targetargsc>T(a"[TS5(a'TR(a[RS5 g[R "5R 5(d[RS5 g[[S5(aC[R"T5T[T5-:nU(d[RS5 U$g)N_manual_cleanupz3Client is being cleaned up, stopping tracing threadFz,Main thread is dead, stopping tracing thread getrefcountzeClient refs count indicates we're the only remaining reference to the client, stopping tracing threadT) rrrpr threading main_threadis_alivesysrrT)should_keep_threadrrnum_known_refs sub_threadss r%keep_thread_active7tracing_control_thread_func..keep_thread_activehs F- . .63I3I LLN O$$&//11 LLG H 3 & &"%!8>CM<" & =& %r'rtrrVrWrVrOrWzHybrid mode cleanupOTEL-only cleanupLangSmith-only cleanupz'Tracing control thread is shutting downrArC)#rUrrrRrrrinstance_flagsrprweakrefWeakSet_futuresr r_rEventrThread-tracing_control_thread_func_compress_parallelrefstartrremoverTqsize_tracing_sub_thread_funcr rrbrZrrrr) client_refrUrrsrrrdisable_compressionrthread new_threadrrmax_batch_sizerXrrrrs @@@r%tracing_control_thread_funcr @sE \F ~((M  $$ $/ <),7J#67P#Q"56N"O'++,DeLM*,KN ""#<= ,   t + = **0b55 &   NNU  &oo/FO'7'9F $+4??+>"))/kk&)=9J   z *    2B2D/!  ( ( "&&'9:   5 N  : )3M}1&-T-M}E   N/?.@+$$X(;(?(?@R(SXWX4u^ *  % LL. / / =  LL, - -fm P LL1 2 ( = !4u^ * & LL:;r'c^ ^ U"5m T cg[RS5 T RbT Rb T Rc[R S5 g[ T R5nUSnT R=(d URSS5nSm SU U 4Sjjn[R"5nT RRS S 9nU"5(dGOU(a~T RR5 [T X45upUb=[R!T R"UU 5n T RR%U 5 [R"5nOy[R"5U- U:a][T S S S 9unn Ub7[(R"[R!T R"UU 5/5 [R"5nGM([T S S S 9un n U b8[(R"[R!T R"U U 5/5 O[RS5 g![&a T R#UU 5 GNf=f![&a T R#UU 5 Nf=f![&a T R#U U 5 Nyf=f![*a [R S SS9 Nf=f)Nz4Tracing control thread func compress parallel calledzLangSmith tracing error: Required compression attributes not initialized. This may affect trace submission but does not impact your application's runtime.rsrt@c>T(a"[TS5(a'TR(a[RS5 g[R "5R 5(d[RS5 g[[S5(a7[R"T5T:nU(d[RS5 U$g)Nrz7Client is being cleaned up, stopping compression threadFz0Main thread is dead, stopping compression threadrziClient refs count indicates we're the only remaining reference to the client, stopping compression threadT) rrrprrrrrr)rrrrs r%rItracing_control_thread_func_compress_parallel..keep_thread_actives F- . .63I3I LLR S$$&//11 LLK L 3 & &"%!8>!I % A& %r'TrQ)rPr)rsrtzuLangSmith tracing error: Failed during final cleanup. This does not affect your application's runtime. Error details:r]z1Compressed traces control thread is shutting downr)rprr_rrrqrrrbrRtime monotonicwaitclearrxLANGSMITH_CLIENT_THREAD_POOLr_send_compressed_multipart_reqaddr~rro)rflush_intervalrrsrtrlast_flush_time triggered data_streamrwfuturefinal_data_streamrrrs @@r%rrs\F ~ LLGH  (  ' ' / ?? "  1 / <),7J337J7N7NJ8 N4nn&O 0055d5C !##    ( ( . . 08j34 /K& 9@@==#.F OO''/ #nn.O ?2~E<q1** < C C$*$I$I$/$:!"#'.."2i n  4 q1   "  ( 4;;"AA-2 )0 LLDEC$99#.4(=='24  55%*        sT/?.@+$$X(;(?(?@R(SXWX4u^ *  % /z  LL, - -fZ P LL1 2 (z 4u^ * $ LL>?G  :A>sH I!H<<I)r!list[TracingQueueItem]rAzAdict[tuple[Optional[str], Optional[str]], list[TracingQueueItem]])rTr) rUrrVrrOrCrWrrAr )rr )rrrrsrrtz int | NonerAz6tuple[Optional[io.BytesIO], Optional[tuple[int, int]]])rrrrzlist[tuple[str, dict]]rArB)TN)rrrrUrr!r rrCrrCrJOptional[list[Union[SerializedRunOperation, SerializedFeedbackOperation]]]rArB) rrrrUrr!r rrCrr!rArB)T) rrrrUrr!r rrCrrCrArB)rrrrArC)rAz Optional[int])rzls_schemas.LangSmithInforAzls_schemas.BatchIngestConfig)rAztuple[bool, bool])rweakref.ref[Client]rArB)g?)rr"rfloatrArB)rr"rrCrArB)? __future__rconcurrent.futuresfuturesrr functoolsiologgingrrrrmultiprocessingrqueuerrtypingrrr r langsmithr rr r&langsmith._internal._compressed_tracesr langsmith._internal._constantsrrrrlangsmith._internal._operationsrrropentelemetry.context.contextrlangsmith.clientr getLoggerrprrr&total_orderingr)rZrxrrrrrrrrr rrrMr'r%r5s"    %,'C  5'   - .!44qQ  ! F  )4)4)4ZWX++!$+37+PS++^KU2 2 #2=G2;2j/ / &</  / n  K KK "K K  K   K Kd  < << "< <   < <H N NN "N N  N  Nb$N  "!03.DANF#NF5:NF NFbM@#M@M@ M@r'