3i :SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSK JrJr SSKJrJrJrJrJrJrJrJrJrJrJrJr SSKJr SSKJr SSK J!r" SS K J#r$ SS K%J&r& SS K'J(r( SS K)J*r*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2 SS K3J4r4 SSK5J6r6 SSK7J8r8J9r9 SSK:J;r; SSKr> SSK?J@r@JArAJBrBJCrC SSKDJErEJFrF SSKGJHrHJIrI SSKJJ r SSKKJLrL \R"\N5rOSrPSrQSrRSrSSrTSrUSrV"SS5rW"SS\W5rX"SS\W5rY"SS \R5r["S!S"\[5r\S#r]S$\FS%\ RS&\_4S'jr`"S(S)5ra"S*S+5rb\b"\bR\bR\bR\bR\bR\bR\bR\bRS,9rd\bRS\/\Q5rf"S-S.\$R\a5rg"S/S0\g5rh"S1S2\$R5ri"S3S4\$R5rjg)5N)environ)time_ns)MappingProxyType TracebackType) AnyCallableDictIteratorListMappingMutableMappingOptionalSequenceTupleTypeUnion)filterwarnings) deprecatedcontext)trace)BoundedAttributes)util) OTEL_ATTRIBUTE_COUNT_LIMIT!OTEL_ATTRIBUTE_VALUE_LENGTH_LIMIT OTEL_EVENT_ATTRIBUTE_COUNT_LIMITOTEL_LINK_ATTRIBUTE_COUNT_LIMITOTEL_SDK_DISABLEDOTEL_SPAN_ATTRIBUTE_COUNT_LIMIT&OTEL_SPAN_ATTRIBUTE_VALUE_LENGTH_LIMITOTEL_SPAN_EVENT_COUNT_LIMITOTEL_SPAN_LINK_COUNT_LIMIT)Resource)sampling) IdGeneratorRandomIdGenerator) BoundedList)InstrumentationInfoInstrumentationScope)EXCEPTION_ESCAPEDEXCEPTION_MESSAGEEXCEPTION_STACKTRACEEXCEPTION_TYPE) NoOpTracer SpanContext)Status StatusCode)types)_agnosticcontextmanagercx\rSrSrSrSSSS\\RSS4SjjrSS jr SS jr SS \ S\ 4S jjr S rg) SpanProcessor\zInterface which allows hooks for SDK's `Span` start and end method invocations. Span processors can be registered directly using :func:`TracerProvider.add_span_processor` and they are invoked in the same order as they were registered. NspanSpanparent_contextreturncg)aJCalled when a :class:`opentelemetry.trace.Span` is started. This method is called synchronously on the thread that starts the span, therefore it should not block or throw an exception. Args: span: The :class:`opentelemetry.trace.Span` that just started. parent_context: The parent context of the span that just started. Nselfr9r;s Z/home/james-whalen/.local/lib/python3.13/site-packages/opentelemetry/sdk/trace/__init__.pyon_startSpanProcessor.on_startecg)zCalled when a :class:`opentelemetry.trace.Span` is ended. This method is called synchronously on the thread that ends the span, therefore it should not block or throw an exception. Args: span: The :class:`opentelemetry.trace.Span` that just ended. Nr>r@r9s rAon_endSpanProcessor.on_endtrDrEcg)zJCalled when a :class:`opentelemetry.sdk.trace.TracerProvider` is shutdown.Nr>r@s rAshutdownSpanProcessor.shutdown~rDrEtimeout_milliscg)zExport all ended spans to the configured Exporter that have not yet been exported. Args: timeout_millis: The maximum amount of time to wait for spans to be exported. Returns: False if the timeout is exceeded, True otherwise. Nr>r@rNs rA force_flushSpanProcessor.force_flushrDrEr>Nr9 ReadableSpanr<Nr<Ni0u)__name__ __module__ __qualname____firstlineno____doc__r context_apiContextrBrHrLintboolrQ__static_attributes__r>rErAr7r7\s[9=    !!4!45      Y  #  $   rEr7c\rSrSr%Sr\\S4\S'SrS\SS4S jr SS S S \ \ RSS4S jjr SSjrSSjrSS\S\4SjjrSrg)SynchronousMultiSpanProcessorzImplementation of class:`SpanProcessor` that forwards all received events to a list of span processors sequentially. The underlying span processors are called in sequential order as they were added. ._span_processorscFSUl[R"5Ulg)Nr>)re threadingLock_lockrKs rA__init__&SynchronousMultiSpanProcessor.__init__s!#^^% rEspan_processorr<Nc|UR U=RU4- slSSS5 g!,(df  g=fz:Adds a SpanProcessor to the list handled by this instance.Nrirer@rls rAadd_span_processor0SynchronousMultiSpanProcessor.add_span_processor' ZZ  ! !n%6 6 !ZZ- ;r9r:r;cHURHnURXS9 M g)Nr;)rerB)r@r9r;sps rArB&SynchronousMultiSpanProcessor.on_starts" ''B KKK <(rEcLURHnURU5 M grS)rerH)r@r9rws rArH$SynchronousMultiSpanProcessor.on_ends''B IIdO(rEcJURHnUR5 M g)z7Sequentially shuts down all underlying span processors.N)rerL)r@rws rArL&SynchronousMultiSpanProcessor.shutdowns''B KKM(rErNc[5US--nURH1n[5nXB:a gURX$- S-5(aM1 g g)aSequentially calls force_flush on all underlying :class:`SpanProcessor` Args: timeout_millis: The maximum amount of time over all span processors to wait for spans to be exported. In case the first n span processors exceeded the timeout followup span processors will be skipped. Returns: True if all span processors flushed their spans within the given timeout, False otherwise. i@BFT)rrerQ)r@rN deadline_nsrwcurrent_time_nss rArQ)SynchronousMultiSpanProcessor.force_flushsTi.7":: ''B%iO->>;#@W"LMM (rErorSrTrVrW)rXrYrZr[r\rr7__annotations__rjrqrr]r^rBrHrLr_r`rQrar>rErArcrcsM3.//& 77479===!!4!45=  = #$rErcc\rSrSrSrSS\4SjjrS\SS4SjrS \ \/\ S 4S \ S \ 4S jr SSSS\ \ RSS4SjjrSSjrSSjrSS\S\4SjjrSrg)ConcurrentMultiSpanProcessoraImplementation of :class:`SpanProcessor` that forwards all received events to a list of span processors in parallel. Calls to the underlying span processors are forwarded in parallel by submitting them to a thread pool executor and waiting until each span processor finished its work. Args: num_threads: The number of threads managed by the thread pool executor and thus defining how many span processors can work in parallel. num_threadscSUl[R"5Ul[R R US9Ulg)Nr>) max_workers)rergrhri concurrentfuturesThreadPoolExecutor _executor)r@rs rArj%ConcurrentMultiSpanProcessor.__init__s:!#^^% #++>>#? rErlr<Nc|UR U=RU4- slSSS5 g!,(df  g=frnrorps rArq/ConcurrentMultiSpanProcessor.add_span_processorrsrtfunc).Nargskwargsc/nURH:nURR"U"U5/UQ70UD6nURU5 M< UHnUR 5 M grS)rersubmitappendresult)r@rrrrrwfutures rA_submit_and_await.ConcurrentMultiSpanProcessor._submit_and_awaits\ ''B^^**48EdEfEF NN6 "(F MMOrEr9r:r;c&URSXS9 g)NcUR$rS)rBrws rA7ConcurrentMultiSpanProcessor.on_start..sr{{rErvrr?s rArB%ConcurrentMultiSpanProcessor.on_starts  "D  rEc*URSU5 g)NcUR$rS)rHrs rAr5ConcurrentMultiSpanProcessor.on_end..s"))rErrGs rArH#ConcurrentMultiSpanProcessor.on_ends 3T:rEc(URS5 g)z6Shuts down all underlying span processors in parallel.cUR$rS)rLrs rAr7ConcurrentMultiSpanProcessor.shutdown..s"++rENrrKs rArL%ConcurrentMultiSpanProcessor.shutdowns 56rErNc8/nURH:nURRURU5nUR U5 M< US- n[ R RX%5upgU(agUHnUR5(aM g g)aCalls force_flush on all underlying span processors in parallel. Args: timeout_millis: The maximum amount of time to wait for spans to be exported. Returns: True if all span processors flushed their spans within the given timeout, False otherwise. g@@FT) rerrrQrrrwaitr)r@rNrrwr timeout_sec done_futuresnot_done_futuress rArQ(ConcurrentMultiSpanProcessor.force_flushs''B^^**2>>>JF NN6 "(%s* )3););)@)@ * &  "F==??#rE)rrire)rSrTrVrW)rXrYrZr[r\r_rjr7rqrrrrr]r^rBrHrLr`rQrar>rErArrs  C 7747  (;;<    9=  !!4!45    ;7#$rErc\rSrSrS S\S\\SS4Sjjr\S\4Sj5r \S\4Sj5r \\ RS\ R4S j55rS rg) EventBasei&Nname timestampr<cBXlUc[5UlgX lgrS)_namer _timestamp)r@rrs rArjEventBase.__init__'s  %iDO'OrEcUR$rSrrKs rArEventBase.name. zzrEcUR$rS)rrKs rArEventBase.timestamp2s rEcgrSr>rKs rA attributesEventBase.attributes6s rE)rrrS)rXrYrZr[strrr_rjpropertyrrabcabstractmethodr2 Attributesrrar>rErArr&s(S(Xc](d(c3 E,,  rErc ^\rSrSrSrSS\4S\S\RS\ \ S\ \ SS4 U4S jjjr \ S\R4S j5r \ S\ 4S j5rS rU=r$) Eventi<zA text annotation with a set of attributes. The attributes of an event are immutable. Args: name: Name of the event. attributes: Attributes of the event. timestamp: Timestamp of the event. If `None` it will filled automatically. Nrrrlimitr<c0>[TU]X5 X lgrS)superrj _attributes)r@rrrr __class__s rArjEvent.__init__Gs )%rEcUR$rSrrKs rArEvent.attributesQrEcn[UR[5(aURR$gNr isinstancerrdroppedrKs rAdropped_attributesEvent.dropped_attributesU+ d&&(9 : :##++ +rEr)rXrYrZr[r\(_DEFAULT_OTEL_SPAN_ATTRIBUTE_COUNT_LIMITrr2rrr_rjrrrra __classcell__rs@rArr<s(,#'G &&$$&C= & } &  && E,,  CrErc^U4SjnU$)Nc>SnUR URc T"U/UQ70UD6 OSnSSS5 U(a![RSTR5 gg!,(df  N7=f)NFTz"Tried calling %s on an ended span.)ri _end_timeloggerwarningrX)r@rr already_endedrs rAwrapper"_check_span_ended..wrapper]sZ ZZ~~%T+D+F+ $   NN? O  Zs A A,r>)rrs` rA_check_span_endedr\s P NrErrr<cv[U=(a( UR=(d U=(d UR5$rS)r`is_valid trace_staterrs rA_is_valid_linkrks- MW%%L**K8K8K rEcp\rSrSrSrSSSSSS\R RS\"\ R5SSS4 S\ S\ \RS\ \RS\ \S \R S \\S \\R&S \R S \ \S\S\ \S\ \S\ \SS4Sjjr\S\4Sj5r\S\4Sj5r\S\4Sj5r\S\ 4Sj5rSr\S5r\S\R 4Sj5r\S\ \R4Sj5r \S\ \4Sj5r!\S\ \4Sj5r"\S\R4Sj5r#\S\R 4Sj5r$\S\\4S j5r%\S\\R&4S!j5r&\S\4S"j5r'\\("S#5S\ \4S$j55r)\S\ \4S%j5r*S-S&\ \4S'jjr+\,S\ S\-\ \ 44S(j5r.\,S \R S\ \-\ \/44S)j5r0\,S \\S\1\-\ \/44S*j5r2\,S \\R&S\1\-\ \/44S+j5r3S,r4g).rUiqzProvides read-only access to span attributes. Users should NOT be creating these objects directly. `ReadableSpan`s are created as a direct result from using the tracing pipeline via the `Tracer`. Nr>rrparentresourcereventslinkskindinstrumentation_infostatus start_timeend_timeinstrumentation_scoper<cXlX lXlXlXlX0lXlXlXPlX`l Xpl Uc[R"05Ul OX@l XlgrS)r_context_kind_instrumentation_info_instrumentation_scope_parent _start_timerr_events_linksr#create _resource_status)r@rrrrrrrrrrrrrs rArjReadableSpan.__init__ys_    %9"&;# %!%   %__R0DN%N rEcn[UR[5(aURR$grrrKs rArReadableSpan.dropped_attributesrrEcn[UR[5(aURR$gr)rrr'rrKs rAdropped_eventsReadableSpan.dropped_eventss& dllK 0 0<<'' 'rEcn[UR[5(aURR$gr)rrr'rrKs rA dropped_linksReadableSpan.dropped_linkss& dkk; / /;;&& &rEcUR$rSrrKs rArReadableSpan.namerrEcUR$rSrrKs rAget_span_contextReadableSpan.get_span_context }}rEcUR$rSr rKs rArReadableSpan.contexts }}rEcUR$rS)rrKs rArReadableSpan.kindrrEcUR$rS)rrKs rArReadableSpan.parent ||rEcUR$rS)rrKs rArReadableSpan.start_timerrEcUR$rSrrKs rArReadableSpan.end_time ~~rEcUR$rS)rrKs rArReadableSpan.statusrrEc>[UR=(d 05$rS)rrrKs rArReadableSpan.attributess 0 0 6B77rEc:[SUR55$)Nc3$# UHov M g7frSr>).0events rA &ReadableSpan.events..s5 uU )tuplerrKs rArReadableSpan.eventss5 555rEc:[SUR55$)Nc3$# UHov M g7frSr>)r$links rAr&%ReadableSpan.links..s2kdTkr()r)rrKs rArReadableSpan.linkss2dkk222rEcUR$rSrrKs rArReadableSpan.resourcerrEzFYou should use instrumentation_scope. Deprecated since version 1.11.1.cUR$rS)rrKs rAr!ReadableSpan.instrumentation_infos )))rEcUR$rS)rrKs rAr"ReadableSpan.instrumentation_scopes***rEindentcSnURb-S[R"URR53nSnUR(a [ R "UR5nSnUR(a [ R "UR5nS[URRR50nURR(aURRUS'URUR(aURUR5OS[UR 5UUUUUR#UR$5UR'UR(5UR+UR,5[.R0"UR2R555S. n[.R6"XaS9$)N0x status_code description) rrr parent_idrrrrrrr)r7)r trace_apiformat_span_idspan_idrr ns_to_iso_strrrrr:rr;rr_format_contextr_format_attributesr_format_eventsr _format_linksrjsonloadsrto_jsondumps)r@r7r<rrrf_spans rArGReadableSpan.to_jsons` ;; "Y55dkk6I6IJKLI   ++D,<,<=J >>))$..9H 3t||77<<=  << # #$(LL$<$r?reprrrs rArAReadableSpan._format_context sRY66w7G7GHIJI44W__EFG 3 34  rEcLUb [U[5(d [U5$U$rS)rdict)rs rArBReadableSpan._format_attributess'  !*Z*F*F # #rEcUVs/sHNnUR[R"UR5[R UR 5S.PMP sn$s snf)N)rrr)rrr@rr:rBr)rr%s rArCReadableSpan._format_eventss_      !//@"55$$     sAAcUVs/sHBn[RUR5[RUR5S.PMD sn$s snf)Nr)r:rArrBr)rr-s rArDReadableSpan._format_links(s[   //LL#55OO     sA A) rrrrrrrrrrrrr))5rXrYrZr[r\r=SpanKindINTERNALr0r1UNSETrrr/r#r2rrrLinkr(r_r)rjrrrrrrrrrrrrrrrrrrrrG staticmethodr rArrBr rCrDrar>rErArUrUqs4826'+'+"$*,#,#5#5#>#>>B 0 01$("&@D)//0../  8$  $$  '  '':;SM3- ((<= BC  s ci((!6!67 HSM  (3- ((8E,,886663x /33(P*h/B&C**+x0D'E++#1hsm#1J  c3h  $$ $sCx. !  x  4S#X3G      Xinn5  $tCH~:N    rErUc\rSrSrSrSrSS\\S\\S\\S\\S \\S \\S \\S \\4S jjrSr \ SS\\S\ S\\S\\4Sjj5r Sr g) SpanLimitsi7aThe limits that should be enforce on recorded data such as events, links, attributes etc. This class does not enforce any limits itself. It only provides an a way read limits from env, default values and from user provided arguments. All limit arguments must be either a non-negative integer, ``None`` or ``SpanLimits.UNSET``. - All limit arguments are optional. - If a limit argument is not set, the class will try to read its value from the corresponding environment variable. - If the environment variable is not set, the default value, if any, will be used. Limit precedence: - If a model specific limit is set, it will be used. - Else if the corresponding global limit is set, it will be used. - Else if the model specific limit has a default value, the default value will be used. - Else if the global limit has a default value, the default value will be used. Args: max_attributes: Maximum number of attributes that can be added to a span, event, and link. Environment variable: OTEL_ATTRIBUTE_COUNT_LIMIT Default: {_DEFAULT_ATTRIBUTE_COUNT_LIMIT} max_events: Maximum number of events that can be added to a Span. Environment variable: OTEL_SPAN_EVENT_COUNT_LIMIT Default: {_DEFAULT_SPAN_EVENT_COUNT_LIMIT} max_links: Maximum number of links that can be added to a Span. Environment variable: OTEL_SPAN_LINK_COUNT_LIMIT Default: {_DEFAULT_SPAN_LINK_COUNT_LIMIT} max_span_attributes: Maximum number of attributes that can be added to a Span. Environment variable: OTEL_SPAN_ATTRIBUTE_COUNT_LIMIT Default: {_DEFAULT_OTEL_SPAN_ATTRIBUTE_COUNT_LIMIT} max_event_attributes: Maximum number of attributes that can be added to an Event. Default: {_DEFAULT_OTEL_EVENT_ATTRIBUTE_COUNT_LIMIT} max_link_attributes: Maximum number of attributes that can be added to a Link. Default: {_DEFAULT_OTEL_LINK_ATTRIBUTE_COUNT_LIMIT} max_attribute_length: Maximum length an attribute value can have. Values longer than the specified length will be truncated. max_span_attribute_length: Maximum length a span attribute value can have. Values longer than the specified length will be truncated. Nmax_attributes max_events max_linksmax_span_attributesmax_event_attributesmax_link_attributesmax_attribute_lengthmax_span_attribute_lengthc 0URU[[5UlURU[[ 5UlURU[5n U bU O[Ul URU[U bU O[5Ul URU[U bU O[5UlURU[ U bU O["5UlURU[&5UlURU[*UR(5UlgrS)_from_env_if_absentr!$_DEFAULT_OTEL_SPAN_EVENT_COUNT_LIMITrar"#_DEFAULT_OTEL_SPAN_LINK_COUNT_LIMITrbr#_DEFAULT_OTEL_ATTRIBUTE_COUNT_LIMITr`rrrcr)_DEFAULT_OTEL_EVENT_ATTRIBUTE_COUNT_LIMITrdr(_DEFAULT_OTEL_LINK_ATTRIBUTE_COUNT_LIMITrerrfr rg) r@r`rarbrcrdrerfrgglobal_max_attributess rArjSpanLimits.__init__ds-22  ' 0  11  & / !% 8 8 6!  %0 "4  $(#;#;  +)4&= $  %)$<$< ,)4&> % !$(#;#;  +)4&= $  %)$<$< -% !*.)A)A % 2  % % * &rEc[U5RSURSURSURSUR SUR SURSURS3$) Nz(max_span_attributes=z, max_events_attributes=z, max_link_attributes=z, max_attributes=z , max_events=z , max_links=z, max_attribute_length=)) typerXrcrdrer`rarbrfrKs rA__repr__SpanLimits.__repr__st*%%&&;D>@I,, EI 19W^^G;< <  E !CDD Es ! B%B3)rfr`rdrarerbrgrc)NNNNNNNNrS)rXrYrZr[r\rZrr_rjrt classmethodrrirar>rErAr^r^7s(T E)-$(#'-1.2-1.237G   G SMG C= G &c] G 'sm G &c]G 'smG $,C=G RMJNSM,/:B3- #rEr^)r`rarbrcrdrerfrgc!,^\rSrSrSrU4SjrSSSSSSS\RR\ "5SSS\ S4S\ S\RS \ \RS \ \RS SS \ \S \R$S\ \\S\\R*S\RS\ S\ \S\S\S\ \SS4 U4SjjjrSrSrS\\R*4SjrSrS \\ \R>4SS4Sjr S\ S\R>SS4Sjr!\"S \#SS4S!j5r$S:S\ S \R$S"\ \%SS4S#jjr&\"S$\R*SS4S%j5r'S;S\ S \R$SS4S&jjr(S\)4S'jr*S:S(\ \%S)\ \+RXSS4S*jjr-S;S+\ \%SS4S,jjr.\"S\ SS4S-j5r/S\4S.jr0\"S;S/\1Rd\3\44S0\1R\ SS4S1jj5r5S2\ \6\7S3\ \7S4\ \8SS4U4S5jjr9SU[La [S5e[TU] U5$)Nz'Span must be instantiated via a tracer.)r: TypeErrorr__new__)rrrrs rAr Span.__new__s% $;EF Fws##rENr>Trrrsampler trace_configrrrrrrlrrecord_exceptionset_status_on_exceptionrr<c |>Uc[R"05n[TU] UUUU UU US9 X@lXPlXlXlXlXl [R"5Ul [URRUSURRS9UlUR#5UlU(afUH`n[URR&UR(URR*S9UlUR$R-U5 Mb UR/U 5Ulg)N)rrrrrrrF) immutable max_value_lenr)r#rrrj_sampler _trace_config_record_exception_set_status_on_exception_span_processor_limitsrgrhrirrcrgr _new_eventsrrdrrfr _new_linksr)r@rrrrrrrrrrrlrrrlimitsrr%rs rArj Span.__init__s&  r*H !5"7   )!1(?%- ^^% , LL , , ,,@@   '') $5LL55$$"&,,"C"C%!  ##E*  ooe, rEcf[U5RSURSURS3$)Nz(name="z ", context=rr)rsrXrrrKs rArt Span.__repr__3s/t*%%&gdjj\T]]OSTUUrEc@[URR5$rS)r'rrarKs rArSpan._new_events6s4<<2233rEcU(d[URR5$/nUHnU(dM [URUR 5(dM3[ URRUR URRS9Ul URU5 M [R"URRU5$)Nr) r'rrbrrrrrerfrrfrom_seq)r@r valid_linksr-s rArSpan._new_links9st||556 6 Dtt||T__EE#4LL44OO"&,,"C"C$ ""4(##DLL$:$:KHHrEcUR$rSr rKs rArSpan.get_span_contextJrrEcUR URb[RS5 SSS5 gUR 5Hup#X0R U'M SSS5 g!,(df  g=f)Nz Setting attribute on ended span.)rirrritemsr)r@rkeyrvs rAset_attributesSpan.set_attributesMs[ZZ~~)ABZ )..0 (-  %1 ZZs$A*'A** A8rrvc&URX05$rS)r)r@rrvs rA set_attributeSpan.set_attributeXs""C<00rEr%c:URRU5 grS)rr)r@r%s rA _add_eventSpan._add_event[s E"rErc[URRUURRS9nUR [ UUUS95 g)Nrrrr)rrrdrfrr)r@rrrs rA add_eventSpan.add_event_sJ ' LL - - ,,;;  %#  rEr-c:URRU5 grS)rr)r@r-s rA _add_linkSpan._add_linkrs 4 rEc[X5(dg[URRUURRS9nUR [ R"UUS95 g)Nrr)rrrrerfrr=r[)r@rrs rAadd_link Span.add_linkvsY g22 & LL , , ,,;;  NN%  rEc0[URURURURUR UR URURURURURURURS9 $)N) rrrrrrrrrrrrr)rUrrrrrrrrrrrrrrKs rA_readable_spanSpan._readable_spansrMM<<^^''<<++<<''^^!%!;!;"&"="=  rErr;cUR URb[RS5 SSS5 gUbUO [ 5UlSSS5 UR R XS9 g!,(df  N(=f)Nz"Calling start() on a started span.rv)rirrrrrrB)r@rr;s rAstart Span.startsj ZZ+CDZ )4 ')    %%d%JZs$A0A00 A>rcRUR URc [S5eURb[R S5 SSS5 gUbUO [ 5UlSSS5 URRUR55 g!,(df  N8=f)Nz$Calling end() on a not started span.zCalling end() on an ended span.) rir RuntimeErrorrrrrrrHr)r@rs rAendSpan.ends ZZ'"#IJJ~~)@A Z*2)=X79DN ##D$7$7$9:ZsUb}UR5(ahUR(aURUSS9 UR(a6UR [ [ RURSU3S95 [TU])XU5 g)z3Ends context manager and calls `end` on the `Span`.NT) exceptionescapedz: )r:r;) rrrrrr0r1ERRORrXr__exit__)r@rrrrs rAr Span.__exit__s  4#4#4#6#6%%%%%F,,$.$4$4'/'8'8&9G9$E F3rErrc SR[R"[U5XRS95n[U5R n[U5R nU(a US:waUSU3OUn[U[[U5[U[[U50n U(aU RU5 URSXS9 g)z%Records an exception as a span event.r5)rvtbbuiltins.rrN)join tracebackformat_exceptionrs __traceback__rYrZr-r+rr,r*updater) r@rrrr stacktracemodulequalnameexception_typers rArSpan.record_exceptionsWW  & &Yy5L5L  i++ ?//&J.haz "  N s9~ * s7| B    z *   rE)rrrrrrirrrrrrrr)NNrS)NNF)=rXrYrZr[r\rr=rXrYr7 _UnsetLimitsrr/rr$Samplerr#r2rrrr[r(r`r)rjrtrrrr AttributeValuerrrrrr_rrrrUrr]r^rrrrtypingrr0r1rr BaseExceptionrrrrarrs@rAr:r:s*$37.2!'+'+,0*,#,#5#5#>#>(5>B!%(,@D#5-5-&&5-../ 5- (**+ 5-  5-8$5-$$5-%)5- '5-  5-&5-'':;5-5-"&5-" ((<=#5-$ %5-5-nV4I 8I" .!#u';';";< .  .11U-A-A1d1# #d## (,#'   $$ C=    &!inn!!! (,  $$    (  &%)8< KSM K!!4!45 K  K ;HSM ;T ;&d&-17 VZ/07__S)7  77:44 ./4-(4' 4  46(,#'    $$ C=       rEr:c\rSrSrSrSrg)_SpanizProtected implementation of `opentelemetry.trace.Span`. This constructor exists to prevent the instantiation of the `Span` class by other mechanisms than through the `Tracer`. r>N)rXrYrZr[r\rar>rErArrsrErc>\rSrSrSrS\R S\S\\ \ 4S\ S\ S\ S \S S 4S jr\S \R$R&S S S SSS4S\S\\R.S\R$S\R2S\\\R6S\\S\S\S\S \\R>4Sjj5r S \R$R&S S S SS4S\S\\R.S\R$S\R2S\\\R6S\\S\S\S \R>4Sjjr!Sr"g )Traceriz!See `opentelemetry.trace.Tracer`.rrrl id_generatorr span_limitsrr<NcXXlX lX0lX@lXPlX`lXplgrS)rrrlrr _span_limitsr)r@rrrlrrrrs rArjTracer.__init__ s,  ,($8!'&;#rEr>Trrrrrrrr end_on_exitc ## URUUUUUUUUS9n [R"U U UUS9n U v SSS5 g!,(df  g=f7f)N)rrrrrrrr)rrr) start_spanr=use_span) r@rrrrrrrrrr9s rAstart_as_current_spanTracer.start_as_current_span4sg!!-$;     #-$;  J    s.A> A A Ac "[R"U5R5n U b*[U [R5(d [ S5eU bU R (dSn URR5n O U Rn URRX*XXE5n U RR5(a.[R"[RR5O-[R"[RR 5n [R"U URR#5SU U R$S9n U RR'5(a{[)UU U URUR*U R,R/5UR0UUUR2UUUR4UR6S9nUR9XbS9 U$[R:"U S9nU$)Nz2parent_span_context must be a SpanContext or None.F) is_remote trace_flagsr)rrrrrrrlrrrrrrr)rr;r)r=get_current_spanrrr/rrrgenerate_trace_idrLr should_sampledecision is_sampled TraceFlagsSAMPLEDDEFAULTgenerate_span_idrrrrrcopyrlrrrrNonRecordingSpan)r@rrrrrrrrparent_span_contextrLsampling_resultr span_contextr9s rArTracer.start_spanSs(88       *: !6!64 4 D   &.A.J.J"& ((::%%i&:&:&B&BC  !,,     . . 0#'33    # # 0 0 2 2$* *55::<#22%)%>%>!1(?((&*&A&AD JJ*J E --lCD rE)rrrrrrrl)#rXrYrZr[r\r$rr#rrcrr%r(r^r)rjr3r=rXrYrrr]r^r2rrr[r_r`r r:rrrar>rErArrs+<!!<< )+G G <"<2< < 4< <(26#,#5#5#>#>'+46$(!%(, +--.   $$  01 SM"& ).. !B26#,#5#5#>#>'+46$(!%(,JJ+--.J  J $$ J 01 JSMJJ"&J JJrErcZ\rSrSrSrSS\\RS\\S\ S\ \ \ S4S\\ S \\S S4S jjr\S \4S j5rSS \S\R \S\R \S\R \R*S S4 SjjrS\S S4SjrSSjrSS\S \ 4SjjrSrg)TracerProvideriz)See `opentelemetry.trace.TracerProvider`.Nrrshutdown_on_exitactive_span_processorrrr<cU=(d [5UlUc[5UlOXPlUc[R "05UlOX lU(d[R"5nXl U=(d [5Ul [R"[S5nUR5R!5S:HUlSUlU(a&[&R("UR*5Ulgg)Nr5true)rc_active_span_processorr&rr#rrr$_get_from_env_or_defaultrr^rrrzrr|r{ _disabled_atexit_handleratexitregisterrL)r@rrrrrrdisableds rArjTracerProvider.__init__s " D%B%D #   1 3D  ,   %__R0DN%N779G '7:<;;0"5!)//1V;# #)??4==#AD  rEcUR$rSr1rKs rArTracerProvider.resourcerrEinstrumenting_module_nameinstrumenting_library_version schema_urlrztrace_api.TracercVUR(a [5$U(dSn[RS5 UcSn[ SS[ SS9 [ UUU5n[URURURURUUR[UUUU55$)Nr5z+get_tracer called with missing module name.ignorezEYou should use InstrumentationScope. Deprecated since version 1.11.1.zopentelemetry.sdk.trace)messagecategoryr)rr.rerrorrDeprecationWarningr(rrrrrrr))r@rrrrrs rA get_tracerTracerProvider.get_tracers >>< ((* % LLF G ( 0,. ) X',   3 % )    LL MM  ' '       )-    rErlc:URRU5 g)zRegisters a new :class:`SpanProcessor` for this `TracerProvider`. The span processors are invoked in the same order they are registered. N)rrqrps rArq!TracerProvider.add_span_processors ##66~FrEcURR5 URb([R"UR5 SUlgg)z;Shut down the span processors added to the tracer provider.N)rrLrr unregisterrKs rArLTracerProvider.shutdownsA ##,,.    +   d22 3#'D  ,rErNc8URRU5$)agRequests the active span processor to process all spans that have not yet been processed. By default force flush is called sequentially on all added span processors. This means that span processors further back in the list have less time to flush their spans. To have span processors flush their spans in parallel it is possible to initialize the tracer provider with an instance of `ConcurrentMultiSpanProcessor` at the cost of using multiple threads. Args: timeout_millis: The maximum amount of time to wait for spans to be processed. Returns: False if the timeout is exceeded, True otherwise. )rrQrPs rArQTracerProvider.force_flushs$**66~FFrE)rrrrrrr)NNTNNN)NNNrVrW)rXrYrZr[r\rr$rr#r`rrcrr%r^rjrrrrr2rr%r7rqrLr_rQrar>rErAr r sL3/3'+!% .2,0B(**+B8$B B % )+G M B{+Bj)B BB( ?C+/8< + #&+ (.s';+ OOC( + OOE$4$45 +  + ZGG4G(G#G$GGrEr )krrconcurrent.futuresrrEloggingrgrrosrtimerr2rrrrr r r r r rrrrrwarningsrtyping_extensionsr opentelemetryrr]rr=opentelemetry.attributesropentelemetry.sdkr'opentelemetry.sdk.environment_variablesrrrrrrr r!r"opentelemetry.sdk.resourcesr#opentelemetry.sdk.tracer$$opentelemetry.sdk.trace.id_generatorr%r&opentelemetry.sdk.utilr'&opentelemetry.sdk.util.instrumentationr(r)5opentelemetry.semconv.attributes.exception_attributesr*r+r,r-opentelemetry.tracer.r/opentelemetry.trace.statusr0r1opentelemetry.utilopentelemetry.util._decoratorr3 getLoggerrXrrlrrmrnrjrkr}r7rcrABCrrrrr`rrUr^rZrriSPAN_ATTRIBUTE_COUNT_LIMITr:rrr r>rErArEs    1    $(0,6"   1,O. 89$A   8 $&)#+.(,/)+.('*$&)#/ / h=M=@S=Sl  ,I@ KU5E5E$ C C LSSl##"((#))"((#))(..  (;;#,r 9>><r j D@Y  @FxGY--xGrE