ޠj8SSKJr 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 `/var/www/html/gaurav/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"nURR%5 SSS5 WR'S5 UWW4$!,(df  N$=f![(a [*R-S S S 9 gf=f) z@Take the filled frame, plus the destination set it committed to.N)NNNrz!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_context destinationsresetseek Exceptionloggererror)client size_limitsize_limit_bytespre_compressed_sizer^ filled_buffercompressed_traces_inforss r*'_tracing_thread_drain_compressed_bufferrs4  # # +#  % % * *"(":":"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 "!33@@L  $ $ * * ,I+L 15|DDO+ *P          s; GGBG&G/C;G*G GGG:9G:c UVVs/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_eventsetrvrwrx) rybatch_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"'EA E"AE"E""FFc [U5nUR5GHuunnn n n n n U(d%[U Vs/sHoRPM sn5nOGU 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$c3@# 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_opsanyrwwarningrCr_batch_ingest_run_opsr rrrvrx_invoke_tracing_error_callback task_donerir0debug)ryrZr& 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+9E:?E0E0AE:,E5E51E:F6&E:: F3%F.)G6.F33G66 G3'G.-G..G36IHI I #'I II I IcUc$[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_batchrwrxrvrrrir0r) ryrZr&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 DD DD DD"D;%D 1DFD7ED E'%E FEF F#'FFFH*F<:H< G9 'G4 -H3G4 4G9 9Hc 2[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(copydeepcopycfThreadPoolExecutorsubmitrrresultrr0rwrrri)ryrZr&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&AC0<DE0 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_varintrirwr)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_endpointr{rzscale_up_nthreads_limitscale_up_qsize_triggerscale_down_nempty_triggerrz) 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)NrzrrrTzUzstandard 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) hasattrrrwr threading main_threadis_alivesysrrY)refcount thresholdshould_keep_threadrynum_known_refs sub_threadss r*keep_thread_active7tracing_control_thread_func..keep_thread_activeqs F- . .63I3I LLN O$$&//11 LLG H 3 & &v.H&[)99I!)!5 % 2 & %r,r{rr[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_disabledrWrrwrris_env_var_truish _tracing_modeinstance_flagsrweakrefWeakSet_futuresrrerEventrThread-tracing_control_thread_func_compress_parallelref_use_daemon_threadsstartrremoverYqsize_tracing_sub_thread_funcr%rhr_rrr) client_refrZrrzrrrdisable_compressionrthread new_threadmodemax_batch_sizer]ryrrs @@@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"5mTcg[RS5 TRbTRb TRc[R S5 g[ TR5nUSnTR=(d URSS5nSmSUU4Sjjn[R"5nTRRS S 9nU"5(dGOU(a~TRR5 [TX45upn Ub<[R!TR"UU U S 9n TRR%U 5 [R"5nOy[R"5U- U:a][TS S S 9unn n Ub6[(R"[R!TR"UU U S 9/5 [R"5nGM(TRbTRR*OSn [RSU 5 [TS S S 9un n n U bz[RSU R-5R.5 [(R"[R!TR"U U U S 9/5 [RS5 O[RS5 [RS5 g![&a TR#UU U S 9 GNf=f![&a TR#UU U S 9 GNLf=f![&a> [RS5 TR#U U U S 9 [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.rzr{@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) rrrwrrrrrr)rrryrs r*rItracing_control_thread_func_compress_parallel..keep_thread_actives F- . .63I3I LLR S$$&//11 LLK L 3 & &v.H!)N!: % 2" & %r,TrV)rU)rsr)rzr{rz.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)rwrrerrrxrrrhrWtime monotonicwaitclearrLANGSMITH_CLIENT_THREAD_POOLr_send_compressed_multipart_reqaddrrrj getbuffernbytesrv)rflush_intervalrrzr{rlast_flush_time triggered data_streamr~rsfuturerjfinal_data_streamryrs @@r*rrs\F ~ LLGH  (  ' ' / ?? "  1 / <),7J337J7N7NJ8 N<nn&O 0055d5C !##    ( ( . . 08jA4 =K& 9@@==#.%1 AF OO''/#nn.O ?2~E <q1 * * < C C$*$I$I$/$:1= !D!"  #'.."2s x6 ''3  $ $ 0 0   <   4 q1   "   ( LLB!++-44  T4;;"AA-2)5 <  MN LLJ K LLDE{$99#.%1::(=='2)5>V T ,55%*!-6  RS T       s];K5K>)A;M+%A L 0M+K;:K;>LL AM(%M+'M((M++N  N c(U"5nUcgUR(dgURnUce[ UR5nUR SS5nSn[R"5R5(aUUS::aUR=(d UR S5=(d Sn[XFUS9=n (aSnURn U S:Xa"[RS 5 [X$X5 OOU S :Xa"[RS 5 [X$U 5 O'[RS 5 [X$X5 OUS - n[R"5R5(a UUS::aMURn UR=(d UR S5=(d Sn[XFSUS9=n (aU S:Xa"[RS5 [X$X5 OIU S :Xa"[RS5 [X$U 5 O![RS5 [X$X5 [XFSUS9=n (aM[RS5 g![a n[RSU5 SnAgSnAff=f)Nz#Error in tracing control thread: %srzrrrr{rrz(Sub-thread handling batch in hybrid moderz&Sub-thread handling batch in otel modez+Sub-thread handling batch in langsmith moderFrz(Sub-thread draining batch in hybrid modez&Sub-thread draining batch in otel modez+Sub-thread draining batch in langsmith modez+Tracing control sub-thread is shutting down)rrrwrrZrrWrrrrhr_rrrr) rrryrrZrrzseen_successive_empty_queuesr r]r s r*rrs\F ~{{  ((M  $$ $/ <$((s;J#$ ((** ( : ; <  ( ( "&&'9:   5 N  : ,- (''Dx GH3: EF1&T JK,: )A - (= ((** ( : ; <>   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 )ryrrzrr{z int | NonerFzKtuple[Optional[io.BytesIO], Optional[tuple[int, int]], Optional[frozenset]])ryrrz&list[tuple[str, dict, dict[str, Any]]]rFrG)TN)ryrrZrr&r"rrHrrHrJOptional[list[Union[SerializedRunOperation, SerializedFeedbackOperation]]]rFrG) ryrrZrr&r"rrHrr#rFrG)T) ryrrZrr&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 getLoggerrwrrr+total_orderingr.r_rrrrrrrr rrrRr,r*r7s"    %<<+'S  5'   - .!44M ! < ?4?4?4FWX++!$+37+PS++^KU8 8 #8 =G8 P8 v2 2 <2  2 t  ] ]] "] ]  ]   ] ]H  = == "= =   = =J N NN "N N  N  Nb  "!0RAoF#oF5:oF oFdK@#K@K@ K@r,