i]SSKrSSKrSSKJr SSKJr SSKJr SSKJ r J r J r J r J r JrJrJr SSKJrJrJrJr SSKJr \"S\S 9r"S S \R25r"S S \\ \5rg)N)abstractmethod) copy_context)partial)AnyCallableDictGenericListOptionalTupleTypeVar) BaseModel ConfigDictField PrivateAttr)BaseSpanT)boundc^\rSrSrSrSSS.S\\S\\S\4S \\S \ \S4S \\ \\4S \\ S S4U4Sjjjjr Sr U=r$)Threadze A wrapper for threading.Thread that copies the current context and uses the copy to run the target. N)daemongrouptarget.nameargskwargsrreturnc>Ub([U/UQ70[U[5(aUO0D64nOSn[TU]U[ 5R UUUS9 g)Nr)rrrrr)r isinstancedictsuper__init__rrun)selfrrrrrr __class__s h/home/james-whalen/.local/lib/python3.13/site-packages/llama_index_instrumentation/span_handlers/base.pyr$Thread.__init__sc  VVJvt4L4L&RTVDD >%%  )NNNrN)__name__ __module__ __qualname____firstlineno____doc__r rrstrr rboolr$__static_attributes__ __classcell__r's@r(rrs $/3" "+/  "& } #s(+, sm  CHo  c3h(      r*rc^\rSrSr%\"SS9r\"\SS9r\ \ \ 4\ S'\"\ SS9r\\ \ S'\"\ SS9r\\ \ S '\"0S S 9r\ \\\ 4\ S '\"5r\\R.\ S '0//04S\ \ \ 4S\\ S \\ S \ \\ 44U4Sjjjr\S\ 4Sj5r\S\R.4Sj5rS#S\ S\R<S\\S\\ S\\ \ \4S\SS4SjjrS$S\ S\R<S\\S\\S\SS4 Sjjr S$S\ S\R<S\\S\\!S\SS4 Sjjr"\#S#S\ S\R<S\\S\\ S\\ \ \4S\S\\ 4Sjj5r$\#S$S\ S\R<S\\S\\S\S\\ 4 S jj5r%\#S$S\ S\R<S\\S\\!S\S\\ 4 S!jj5r&S"r'U=r($)%BaseSpanHandler.T)arbitrary_types_allowedzDictionary of open spans.)default_factory description open_spanszList of completed spans.completed_spans dropped_spansz&Id of current spans in a given thread.)defaultr:current_span_ids_lockc4>[TU]UUUUS9 SUlg)N)r;r<r=r?)r#r$r@)r&r;r<r=r?r's r(r$BaseSpanHandler.__init__>s, !+'-   r*rcg)z Class name.r6r)clss r( class_nameBaseSpanHandler.class_nameMs!r*chURc[R"5UlUR$)N)r@ threadingLock)r&s r(lockBaseSpanHandler.lockRs$ :: ")DJzzr*Nid_ bound_argsinstance parent_idtagsrc XR;agURUUUUUS9nU(a$UR XpRU'SSS5 gg!,(df  g=f)zLogic for entering a span.)rLrMrNparent_span_idrPN)r;new_spanrJ)r&rLrMrNrOrPrspans r( span_enterBaseSpanHandler.span_enterXs] // ! ==%!( !DYY+/OOC(YYs A Aresultc URXX4S9nU(a#UR URU SSS5 gg!,(df  g=f)zLogic for exiting a span.)rLrMrNrWN)prepare_to_exit_spanrJr;)r&rLrMrNrWrrTs r( span_exitBaseSpanHandler.span_exitpH((X)  OOC(  < A errc URXX4S9nU(a#UR URU SSS5 gg!,(df  g=f)z*Logic for dropping a span i.e. early exit.)rLrMrNr^N)prepare_to_drop_spanrJr;)r&rLrMrNr^rrTs r( span_dropBaseSpanHandler.span_dropr\r]rRc g)z Create a span. Subclasses of BaseSpanHandler should create the respective span type T and return it. Only NullSpanHandler should return a None here. Nr)r&rLrMrNrRrPrs r(rSBaseSpanHandler.new_span r*c g)z Logic for preparing to exit a span. Subclasses of BaseSpanHandler should return back the specific span T that is to be exited. If None is returned, then the span won't actually be exited. Nr)r&rLrMrNrWrs r(rY$BaseSpanHandler.prepare_to_exit_spanrer*c g)z Logic for preparing to drop a span. Subclasses of BaseSpanHandler should return back the specific span T that is to be dropped. If None is returned, then the span won't actually be dropped. Nr)r&rLrMrNr^rs r(r`$BaseSpanHandler.prepare_to_drop_spanrer*)r@)NNN)NN))r+r,r-r.r model_configrr"r;rr0r__annotations__listr<r r=r?rr rr@rHrIr$ classmethodrEpropertyrJinspectBoundArgumentsrUrZ BaseExceptionrarrSrYr`r2r3r4s@r(r6r6.sd;L$*E JS!V  %*D OT!W#*DM4727 H2d3 -.'2mE8INN #3$&#%!#+- aL a Aw  sCx.  !3!!inn#'#')- 0 0**03- 0 C= 0 tCH~& 00 08#' $ ) )**)3- )  )  ) )(#''+ ) )**)3- ) m $ )  ) )  #'(,)-   ** 3-  !  tCH~&    !  " #' $   ** 3-       !  " #''+   ** 3-  m $     !  r*r6)rorHabcr contextvarsr functoolsrtypingrrrr r r r r pydanticrrrr%llama_index_instrumentation.span.baserrrr6rr*r(rxsX$OOO>>: Cx  Y   >V iV r*