lQjSSKJr SSKJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK Jr SSKJrJr SSKJrJrJrJrJr SSKJr SSKJr SSKJrJr SS K J!r!J"r"J#r#J$r$ SS K%J&r&J'r'J(r( \(a SS K)J*r* SS K+J,r, \RZ"S 5r.\R^"\"5S9r0SSjr1\Rd"SS55r3SSSjjr4S S!Sjjr5S"Sjr6S#S$Sjjr7S#S%Sjjr8S&S'Sjjr9S(Sjr:S)Sjr;S*Sjr<S+S,Sjjr=S-Sjr>g).) annotationsN) cpu_count)EmptyQueue) TYPE_CHECKINGAnyOptionalUnioncast)schemas)utils)ZSTD_AVAILABLECompressedTraces)_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"[5nUHZnURURUR UR URUR4nX$RU5 M\ U$)z3Group batch items by endpoint and auth combination.r) defaultdict) collectionsrlistapi_urlapi_key service_key tenant_id authorizationcookieappend)batchrgroupeditemkeys c/home/mande/repo/quber/.venv/lib/python3.13/site-packages/langsmith/_internal/_background_thread.py_group_batch_by_api_endpointr+)si($G LL LL    NN    KK    D! Nc\rSrSr%SrS\S'S\S'S\S'S\S 'S\S 'S\S 'S\S 'S\S 'S\S'SrSSSjjrSSjrSSjr Sr g)TracingQueueItemGzAn 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]rr r!r"r#r$Optional[Context] otel_context r1r(r rr!r"r#r$r5Nc pXlX lX0lX@lXPlX`lXplXlXlgNr6) selfr1r(r rr!r"r#r$r5s r*__init__TracingQueueItem.__init__gs4!    &"* (r,cURURR4URURR4:$r8)r1r( __class__r9others r*__lt__TracingQueueItem.__lt__}s; tyy223 NN JJ 7   r,c[U[5=(aE URURR4URURR4:H$r8) isinstancer.r1r(r=r>s r*__eq__TracingQueueItem.__eq__sM%!124 MM II  8 nnejj22 384 4r,) r rr#r$r(r5r1r!r")NNNNNNN)r1r0r(r2r r3rr3r!r3r"r3r#r3r$r3r5r4returnNone)r?r.rFbool)r?objectrFrH) __name__ __module__ __qualname____firstlineno____doc____annotations__ __slots__r:r@rD__static_attributes__r,r*r.r.GsM DD    ## I "&!%%)#''+ $*.))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_queuelimitrTmax_size_bytes next_batch current_sizer(s r*_tracing_thread_drain_queuer_s*,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 URRR5nURRn[[[U5SURR 5 X44nURR#5 SSS5 WR%S5 UW4$!,(df  N#=f![&a [(R+SS S 9 gf=f) N)NNrz!size_limit must be positive; got z*size_limit_bytes must be nonnegative; got z--z-- contextuLangSmith 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_writerwriterencodeclosebuffertellsetattrr r_contextresetseek Exceptionloggererror)client size_limitsize_limit_bytespre_compressed_sizer^ filled_buffercompressed_traces_infos r*'_tracing_thread_drain_compressed_bufferr~s3  # # +  % % * *"(":":"L"L %;;O?O %*/ #DZL!QRR+0@10D @AQ@RS !(,?,R"f&>&>&J&JZ&W!#+ *(  $ $ 6 6 < <YKv&--/   $ $ 6 6 < < >!33::??AL"44;;M S-(((11  ':%H "  $ $ * * ,G+J 1566M+ *N       s; GGBF1&G/C%F1G1 F?;GG#"G#cUVVs/sHup#o#PM nnnUVs/sHoURS5PM nnURc [S5e[URU55n[ U5[ U5:wa#[ S[ U5S[ U535eUVs/sHoURS5PM nnX:wa[ SUSU35e[ X5H>uuppU S:XaUR"U 40U D6 M#U S:XdM+UR"U 40U D6 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:Trc)rW_process_buffered_run_ops RuntimeErrorrrYrizip _create_run _update_run_data_available_eventsetrurvrw) rxbatch_to_process_run_data run_dictsrun original_idsprocessed_runs processed_ids operation write_ctx processed_runs r*_process_buffered_run_ops_batchrs - 4DE4D.!qX4D E1:;#  ;  + + 3S f>>yIJ ~ #i. 0 N+6#n2E1FH  3AA.3. A  ((> @  9< 9 4 %Y9F"""=>I>g%""=>I> 9   ' '  ( ( , , . (EF; B&       s@E%EE%EA3E%)E A E%AE%E%%FFc [U5nUR5GH!uunnn n n n n U(d&[U Vs/sHoRPM sn5nOIU Vs1sHoRRiM nnUVs/sHnURU;dMUPM nnU(aUR UUUU U U U S9 M[ SU55(a>[RS5 UVs/sHn[U[5(aMUPM nnUR[[[U5UUU U U U S9 GM$ U(aUbUHnUR%5 M gggs snfs snfs snfs snf![a/n[R!SSS9 UR#U5 SnANoSnAff=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. )rr r!r"r#r$c3B# UHn[U[5v M g7fr8)rCr).0ops r* /_tracing_thread_handle_batch..[sWYrz"&ABBYsz;Feedback operations are not supported in non-multipart moderbTrcN!task_done() called too many times3Ignoring harmless task_done error during shutdown: )r+itemsrr(r_multipart_ingest_opsanyrvwarningrCr_batch_ingest_run_opsr rrrurw_invoke_tracing_error_callback task_donerir0debug)rxrZr& use_multipartmark_task_doneopsgrouped_batchesrr r!r"r#r$ group_batchr( group_ops group_idsrers r*_tracing_thread_handle_batchr&s,G6u=*//1        ?+67;4YY;7 7BBkdYY\\k B*-D#B)1CR# D,,## +'"/!-WYWWWNNU #,!"+B)".IJ"+! ,,45yA## +'"/!-;2` m7 !++-8>[8CD"! 1    --a001":c!fD QRSQTU m7 !++-!:c!fD QRSQTU8>s9E>E*  E>E/;E>E4E4AE>/E9 E91E>F:*E>> F7%F2-G:2F77G:: G7'G21G22G7:I" HI" I ''I I"I I I"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/n [RSSS9 URU 5 Sn A NjSn A ff=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:Trcrr)rr(rCrrr5 otel_exporter export_batchrvrwrurrrir0r) rxrZr&rrr(rrun_opsotel_context_maprrs r*!_otel_tracing_thread_handle_batchrs() ;5U6SUTyyU6STC #N"z"6L'M2N $))%;< ,DIILL$++ +  ##/$$11'L B m7 !++-8>77TN  1    --a001":c!fD QRSQTU m7 !++-!:c!fD QRSQTU8>s D D D D DD #D>%D#1D FD :ED E*%EFEF F&'FFFH-F?=H? G< 'G7 0H6G7 7G< <Hc 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(copydeepcopycfThreadPoolExecutorsubmitrrresultrr0rvrrri)rxrZr&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[R"S5nUb [U5$g![a [R SUS35 gf=f)NBATCH_INGEST_SIZE_LIMITz+Invalid value for BATCH_INGEST_SIZE_LIMIT: z, continuing with default)ls_utils get_env_varintrirvr)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)NTd)use_multipart_endpointrzryscale_up_nthreads_limitscale_up_qsize_triggerscale_down_nempty_triggerry) ls_schemasBatchIngestConfigrrrbatch_ingest_configr BaseException)infodefault_configenv_size_limits r*_ensure_ingest_configr&s 11# =;"A N ''! !02  %5C $ $\ 2''' sA*&A** A98A9c^^^U"5mTcgTRnUce[TR5nUSnUSnUSnTR(+=(a UR SS5n/mSm[ (d[ RS5 [R"S5=(d! TRS ;=(d [ (+nU(dU(aTRR=(d 0R S S 5(d[ RS 5 O[R"5Tl[!5Tl[$R&"5Tl[$R*"[,[R."T54TR0S 9R35 TS- mSUUU4SjjnU"5(Ga{TH+n U R55(aMTR7U 5 M- [9T5U:aoUR;5U:a[[$R*"[<[R."T5U4TR0S 9n TR?U 5 U R35 TRn TR@=(d UR S5=(d Sn [CXU S9=n (asU S:Xa#[ RS5 [ETXU5 OJU S:Xa"[ RS5 [GTX5 O"[ RS5 [ITXU5 U"5(aGM{[ RSUR;55 TRn TR@=(d UR S5=(d Sn [CXS U S9=n (aU S:Xa#[ RS5 [ETXU5 OJU S:Xa"[ RS5 [GTX5 O"[ RS5 [ITXU5 [CXS U S9=n (aM[ RS5 g)NryrrrTzUzstandard package is not installed. Falling back to uncompressed multipart ingestion.DISABLE_RUN_COMPRESSION)otelhybridzstd_compression_enabledFz~Run compression is not enabled. Please update to the latest version of LangSmith. Falling back to regular multipart ingestion.)targetargsdaemonc>T(a"[TS5(a'TR(a[RS5 g[R "5R 5(d[RS5 g[[S5(aH[R"T5nT[T5-nX:nU(d[RSUU5 U$g)N_manual_cleanupz3Client is being cleaned up, stopping tracing threadFz,Main thread is dead, stopping tracing thread getrefcountzClient refs count indicates we're the only remaining reference to the client, stopping tracing thread (refcount=%d, threshold=%d)T) hasattrrrvr threading main_threadis_alivesysrrY)refcount thresholdshould_keep_threadrxnum_known_refs sub_threadss r*keep_thread_active7tracing_control_thread_func..keep_thread_activeos F- . .63I3I LLN O$$&//11 LLG H 3 & &v.H&[)99I!)!5 % 2 & %r,rzrr[r\rzHandling batch in hybrid moderzHandling batch in otel modez Handling batch in langsmith modez/Tracing thread draining queue on exit: qsize=%dr[rTr\zDraining batch in hybrid modezDraining batch in otel modez Draining batch in langsmith modez'Tracing control thread is shutting downrFrH)%rZrr_multipart_disabledrWrrvrris_env_var_truish _tracing_modeinstance_flagsrweakrefWeakSet_futuresrrerEventrThread-tracing_control_thread_func_compress_parallelref_use_daemon_threadsstartrremoverYqsize_tracing_sub_thread_funcr%rhr_rrr) client_refrZrryrrrdisable_compressionrthread new_threadmodemax_batch_sizer]rxrrs @@@r*tracing_control_thread_funcr >s \F ~((M  $$ $/ <),7J#67P#Q"56N"O2227J7N7N $8M+-KN >  @ ""#<=    #5 5   = **0b55 &   NNU  &oo/FO'7'9F $+4??+>"))/kk&)=911J   z *    ##  ( ( "&&'9:   5 N  : x <=3M} :;1&-T ?@,M}G   P LL9   D$$X(;(?(?@R(SXWX4u^ *  8  LL8 9 / = V^ LL6 7 -fm P LL; < ( = 4u^ *   LL:;r,c$^ ^U"5m T cg[RS5 T RbT Rb T Rc[R S5 g[ T R5nUSnT R=(d URSS5nSmSU U4Sjjn[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 RbT RR*OS n [RSU 5 [T S S S 9un n U b{[RSU R-5R.5 [(R"[R!T R"U U 5/5 [RS5 O[RS5 [RS5 g![&a T R#UU 5 GNf=f![&a T R#UU 5 GNNf=f![&a? [RS5 T R#U U 5 [RS5 Nf=f![0a [R SSS9 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.ryrz@c>T(a"[TS5(a'TR(a[RS5 g[R "5R 5(d[RS5 g[[S5(a;[R"T5nUT:nU(d[RSUT5 U$g)Nrz7Client is being cleaned up, stopping compression threadFz0Main thread is dead, stopping compression threadrzClient refs count indicates we're the only remaining reference to the client, stopping compression thread (refcount=%d, threshold=%d)T) rrrvrrrrrr)rrrxrs r*rItracing_control_thread_func_compress_parallel..keep_thread_actives F- . .63I3I LLR S$$&//11 LLK L 3 & &v.H!)N!: % 2" & %r,TrV)rUr)ryrzrz.Compression thread final flush: trace_count=%dz0Compression thread final flush: sending %d bytesz.Compression thread final flush: send completedzKCompression thread final flush: thread pool shutdown, sending synchronouslyz3Compression thread final flush: sync send completedz/Compression thread final flush: no data to sendzuLangSmith tracing error: Failed during final cleanup. This does not affect your application's runtime. Error details:rcz1Compressed traces control thread is shutting downr)rvrrerrrwrrrhrWtime monotonicwaitclearr~LANGSMITH_CLIENT_THREAD_POOLr_send_compressed_multipart_reqaddrrrj getbuffernbytesru)rflush_intervalrryrzrlast_flush_time triggered data_streamr}futurerjfinal_data_streamrxrs @@r*rrs|\F ~ LLGH  (  ' ' / ?? "  1 / <),7J337J7N7NJ8 N<nn&O 0055d5C !##    ( ( . . 08j34 /K& 9@@==#.F OO''/ #nn.O ?2~E<q1** < C C$*$I$I$/$:!"#'.."2i n3 ''3  $ $ 0 0   <   4 q1   "  ( LLB!++-44  T4;;"AA-2 MN LLJ K LLDEm$99#.4(=='2P T ,55%* RS T       s]   D$$X(;(?(?@R(SXWX4u^ *  8  LLC D /z V^ LLA B -fZ P LLF G (z 4u^ *   LL>?C  :A>sI'' J1J  J)r&list[TracingQueueItem]rFz}dict[tuple[Optional[str], Optional[str], Optional[str], Optional[str], Optional[str], Optional[str]], list[TracingQueueItem]])rTr) rZrr[rrTrHr\rrFr!)rr )rxrryrrzz int | NonerFz6tuple[Optional[io.BytesIO], Optional[tuple[int, int]]])rxrrz0list[tuple[str, dict, dict[str, Optional[str]]]]rFrG)TN)rxrrZrr&r!rrHrrHrJOptional[list[Union[SerializedRunOperation, SerializedFeedbackOperation]]]rFrG) rxrrZrr&r!rrHrr"rFrG)T) rxrrZrr&r!rrHrrHrFrG)rFz Optional[int])rzls_schemas.LangSmithInforFzls_schemas.BatchIngestConfig)rweakref.ref[Client]rFrG)g?)rr#rfloatrFrG)rr#rrHrFrG)? __future__rconcurrent.futuresfuturesrr functoolsiologgingrrrrmultiprocessingrqueuerrtypingrrr r r langsmithr rr r&langsmith._internal._compressed_tracesrrlangsmith._internal._constantsrrrrlangsmith._internal._operationsrrropentelemetry.context.contextrlangsmith.clientr getLoggerrvrrr+total_orderingr.r_r~rrrrrrr rrrRr,r*r6s"    %<<+'S  5'   - .!44M ! < ?4?4?4FWX++!$+37+PS++^KU6 6 #6=G6;6r2 2 F2  2 t  ] ]] "] ]  ]   ] ]H  = == "= =   = =J N NN "N N  N  Nb  "!0RAgF#gF5:gF gFTK@#K@K@ K@r,