Ig>\ddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z mZddlmZddlmZmZmZddlmZmZmZe rddlmZej8d Zej<Gd d Z d dd Z dd Z! ddZ"ddZ# ddZ$y)) annotationsN)EmptyQueue) TYPE_CHECKINGListUnioncast)schemas)_AUTO_SCALE_DOWN_NEMPTY_TRIGGER_AUTO_SCALE_UP_NTHREADS_LIMIT_AUTO_SCALE_UP_QSIZE_TRIGGER)SerializedFeedbackOperationSerializedRunOperation#combine_serialized_queue_operations)Clientzlangsmith.clientcNeZdZUdZded<ded<dZ d dZd dZd d Zy )TracingQueueItemzAn item in the tracing queue. Attributes: priority (str): The priority of the item. action (str): The action associated with the item. item (Any): The item itself. strpriority:Union[SerializedRunOperation, SerializedFeedbackOperation]itemrrc ||_||_yNr)selfrrs c/var/www/html/answerous/venv/lib/python3.12/site-packages/langsmith/_internal/_background_thread.py__init__zTracingQueueItem.__init__1s !  c|j|jjf|j|jjfkSr)rr __class__rothers r__lt__zTracingQueueItem.__lt__9s; tyy223 NN JJ 7   rct|txrE|j|jjf|j|jjfk(Sr) isinstancerrrr r!s r__eq__zTracingQueueItem.__eq__?sM%!124 MM II  8 nnejj22 384 4rN)rrrrreturnNone)r"rr'bool)r"objectr'r)) __name__ __module__ __qualname____doc____annotations__ __slots__rr#r&rrrr"sEM DD$II   4rrcg} |j|dx}r|j||j|dx}r:|j||rt||k\r |S|j|dx}r:|S#t$rY|SwxYw)Ng?)blocktimeoutg?)getappendlenr) tracing_queuelimitr3 next_batchrs r_tracing_thread_drain_queuer;Fs*,J  !$$5$$? ?4 ?   d ##''eT'BBdB   d #ZE1  $''eT'BBdB     sAA;#A;; BBc t|Dcgc]}|jc}}|r|j|nmtd|Dr5tj d|Dcgc]}t |tr|}}|jttt||D]}|jycc}wcc}w#t$rtjddYDwxYw#|D]}|jwxYw)Nc3<K|]}t|tywr)r%r).0ops r z/_tracing_thread_handle_batch..fsM2:b"=>Msz;Feedback operations are not supported in non-multipart modezError in tracing queueT)exc_info)rr_multipart_ingest_opsanyloggerwarnr%r_batch_ingest_run_opsr rr Exceptionerror task_done)clientr8batch use_multipartropsr?_s r_tracing_thread_handle_batchrO[s &12O4992OP   ( ( -MMM Q"%Jr;V,WB  ( (d3I.JC)P Q &A  # # % &'3P   - =   &A  # # % &sF CB>AC$C:C>(C> C C+(C.*C++C..Dctjdddttt}|s|S |j s|S|j S#t $r|cYSwxYw)NFd)use_multipart_endpointsize_limit_bytes size_limitscale_up_nthreads_limitscale_up_qsize_triggerscale_down_nempty_trigger) ls_schemasBatchIngestConfigr r r batch_ingest_config BaseException)infodefault_configs r_ensure_ingest_configr^ysf 11$ =;"A N ''! !''' s A A AAc | y j}|Jt j}|d}|d}|d}|jdd}g d d fd }|r D]$}|j r j |&t |krd|j|kDrQtjttj |f} j| | jt|| x} rt! || ||rt||d x} r t! || |t||d x} ryy) NrTrUrVrRFcrtdr jrytjj sytt dr$t j tzkDSy)N_manual_cleanupF getrefcountT)hasattrrb threading main_threadis_alivesysrcr7)rJnum_known_refs sub_threadssrkeep_thread_activez7tracing_control_thread_func..keep_thread_activesc F- .63I3I$$&//1 3 &??6*^c+>N-NN Nr)targetargsr9r9r3)r'r))r8r^r\r5rgremover7qsizereThread_tracing_sub_thread_funcweakrefrefr6startr;rO) client_refr8rZrTrUrVrLrkthread new_threadr:rJrirjs @@@rtracing_control_thread_funcrzs \F ~((M  $$ $/ <),7J#67P#Q"56N"O'++,DeLM*,KN(  ! +F??$""6* +  6 6##%(>>"))/kk&)=9J   z *    4]*U U: U ( z=   &4Zu *  %V]J V4Zu * rcT|}|y |jsy |j}|Jt |j}|j dd}d}tjjrX||dkrPt||x}rd}t||||n|dz }tjjr ||dkrPt||d x}r t||||t||d x}ryy#t$r }tjd|Yd}~yd}~wwxYw) Nz#Error in tracing control thread: %srTrQrrWrnFro) r\r[rDdebugr8r^r5rerfrgr;rO) rwrLrJer8rZrTseen_successive_empty_queuesr:s rrsrss]\F ~{{  ((M  $$ $/ <$((s;J#$ ((* ( : ; <5]*U U: U+, ( ( z=  )A - ( ((* ( : ; <4Zu *  %V]J V4Zu * 5  :A>s C>> D'D""D')rQT)r8rr9intr3r)r'List[TracingQueueItem]) rJrr8rrKrrLr)r'r()r\zls_schemas.LangSmithInfor'zls_schemas.BatchIngestConfig)rwweakref.ref[Client]r'r()rwrrLr)r'r()% __future__r functoolsloggingrhrertqueuerrtypingrrrr langsmithr rXlangsmith._internal._constantsr r r langsmith._internal._operationsrrrlangsmith.clientr getLoggerrDtotal_orderingrr;rOr^rzrsr1rrrs" ,  '   - .  4 4 4H;?!$37*& && "& &  &< "!*:Wz'W#'W'W 'Wr