xtj ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z mZmZmZddlmZddlmZddlmZddlmZmZddl mZddlmZdd lmZdd lmZ dd lm!Z"dd lm#Z$dd l%m&Z&ddl'm(Z(ddl)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3ddl4m5Z5ddl6m7Z7m8Z8ddl9m:Z:ddl;mZ>m?Z?ddl@mAZAddlBmCZCddlDmEZEmFZFddlGmHZHmIZImJZJmKZKddlLmMZMmNZNddlOmPZPmQZQddlRmZddlSmTZTejUeVZWdZXdZYdZZdZ[dZ\dZ]dZ^Gdd Z_Gd!d"e_Z`Gd#d$e_ZaGd%d&ejbZcGd'd(ecZdd)Zed*eNd+ejfd,egfd-ZhGd.d/ZiGd0d1Zjejejjkejjkejjkejjkejjkejjkejjkejjk2Zlejmde0eYZnGd3d4e$joeiZoGd5d6eoZpeGd7d8ZqGd9d:e$jrZre eFgeqfZseCeqZtd;eFd,eqfd<Zud;eFd,eqfd=ZvGd>d?e$jwZwdS)@N)CallableIteratorMappingMutableMappingSequence) dataclass)environ)time_ns)MappingProxyType TracebackType)Any)filterwarnings) deprecatedcontext)metrics)trace)BoundedAttributes)util) OTEL_ATTRIBUTE_COUNT_LIMIT!OTEL_ATTRIBUTE_VALUE_LENGTH_LIMIT OTEL_EVENT_ATTRIBUTE_COUNT_LIMITOTEL_LINK_ATTRIBUTE_COUNT_LIMIT(OTEL_PYTHON_SDK_INTERNAL_METRICS_ENABLEDOTEL_SDK_DISABLEDOTEL_SPAN_ATTRIBUTE_COUNT_LIMIT&OTEL_SPAN_ATTRIBUTE_VALUE_LENGTH_LIMITOTEL_SPAN_EVENT_COUNT_LIMITOTEL_SPAN_LINK_COUNT_LIMIT)"parse_boolean_environment_variable)Resource_get_process_dependent_resource)sampling)create_tracer_metrics) IdGeneratorRandomIdGenerator) BoundedList)RuleBasedConfigurator)InstrumentationInfoInstrumentationScope)EXCEPTION_ESCAPEDEXCEPTION_MESSAGEEXCEPTION_STACKTRACEEXCEPTION_TYPE) NoOpTracer SpanContext)Status StatusCode)types)_agnosticcontextmanagercdeZdZdZ ddddejdzddfdZddZdd Zdd Z dd e de fdZ dS) SpanProcessoraInterface 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_contextreturncdS)azCalled 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 ^/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/opentelemetry/sdk/trace/__init__.pyon_startzSpanProcessor.on_startccdS)a&Called when a :class:`opentelemetry.trace.Span` is ending. 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 is ending. Nr>r@r9s rA _on_endingzSpanProcessor._on_endingrrCrD ReadableSpancdS)a&Called 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>rFs rAon_endzSpanProcessor.on_end|rCrDcdS)zJCalled when a :class:`opentelemetry.sdk.trace.TracerProvider` is shutdown.Nr>r@s rAshutdownzSpanProcessor.shutdownrCrD0utimeout_milliscdS)a+Export 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. Tr>r@rOs rA force_flushzSpanProcessor.force_flushs trDNr9r:r<Nr9rHr<Nr<NrN) __name__ __module__ __qualname____doc__ context_apiContextrBrGrJrMintboolrRr>rDrAr8r8Zs6:     $+d2                YYYY  # $      rDr8ceZdZUdZeedfed<dZdeddfdZ dd d d e j dzddfd Z dd Z ddZ ddZddedefdZdS)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_processorscDd|_tj|_dS)Nr>)rb threadingLock_lockrLs rA__init__z&SynchronousMultiSpanProcessor.__init__s!#^%% rDspan_processorr<Nch|j5|xj|fz c_ddddS#1swxYwYdSz:Adds a SpanProcessor to the list handled by this instance.Nrfrbr@rhs rAadd_span_processorz0SynchronousMultiSpanProcessor.add_span_processor Z 7 7  ! !n%6 6 ! ! 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 '++r9r:r;cH|jD]}|||dS)Nr;)rbrB)r@r9r;sps rArBz&SynchronousMultiSpanProcessor.on_starts9 ' = =B KK^K < < < < = =rDcD|jD]}||dSrS)rbrGr@r9rrs rArGz(SynchronousMultiSpanProcessor._on_endings3'  B MM$      rDrHcD|jD]}||dSrS)rbrJrts rArJz$SynchronousMultiSpanProcessor.on_ends/'  B IIdOOOO  rDcB|jD]}|dS)z7Sequentially shuts down all underlying span processors.N)rbrM)r@rrs rArMz&SynchronousMultiSpanProcessor.shutdowns-'  B KKMMMM  rDrNrOct|dzz}d}|jD]8}t}||krdS|||z dzdurd}9|S)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@BTF)r rbrR)r@rO deadline_ns all_flushedrrcurrent_time_nss rArRz)SynchronousMultiSpanProcessor.force_flushsii.7"::  ' $ $B%iiO+--uu o ='IJJ$ rDrSrTrUrVrW)rXrYrZr[tupler8__annotations__rgrmr\r]rBrGrJrMr^r_rRr>rDrArarasM3.////&&& 77477776:===$+d2=  ====     #$rDraceZdZUdZeedfed<ddefdZdeddfd Z d eddfd Z d e ege d fde de fdZ ddddejdzddfdZddZddZd dZd!dedefdZdS)"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. .rb num_threadsc d|_tj|_|t t dr7tj|jdfd }t j |dSdS)Nr>register_at_forkr<c:}| |dSdSrSr>)reinitr weak_reinits rA_after_in_childz>ConcurrentMultiSpanProcessor.__init__.._after_in_childs2$%F;'''''&%rDafter_in_childrV) rbrdrerf_init_executorhasattrosweakref WeakMethodr)r@rrrs ` @rArgz%ConcurrentMultiSpanProcessor.__init__s!#^%%  K((( 2) * * @",T-@AAK ( ( ( ( ( ( (   ? ? ? ? ? ? @ @rDr<NcPtj||_dS)N) max_workers) concurrentfuturesThreadPoolExecutor _executor)r@rs rArz+ConcurrentMultiSpanProcessor._init_executors(#+>>#?  rDrhch|j5|xj|fz c_ddddS#1swxYwYdSrjrkrls rArmz/ConcurrentMultiSpanProcessor.add_span_processorrnrofunc).Nargskwargscg}|jD]6}|jj||g|Ri|}||7|D]}|dSrS)rbrsubmitappendresult)r@rrrrrrfutures rA_submit_and_awaitz.ConcurrentMultiSpanProcessor._submit_and_await s ' # #B*T^*4488EdEEEfEEF NN6 " " " "  F MMOOOO  rDr9r:r;c8|d||dS)Nc|jSrS)rBrrs rAz7ConcurrentMultiSpanProcessor.on_start.. sr{rDrqrr?s rArBz%ConcurrentMultiSpanProcessor.on_starts5  " "D      rDc4|d|dS)Nc|jSrS)rGrs rArz9ConcurrentMultiSpanProcessor._on_ending..%s"-rDrrFs rArGz'ConcurrentMultiSpanProcessor._on_ending#s" 77>>>>>rDrHc4|d|dS)Nc|jSrS)rJrs rArz5ConcurrentMultiSpanProcessor.on_end..(s")rDrrFs rArJz#ConcurrentMultiSpanProcessor.on_end's" 33T:::::rDc2|ddS)z6Shuts down all underlying span processors in parallel.c|jSrS)rMrs rArz7ConcurrentMultiSpanProcessor.shutdown..,s"+rDNrrLs rArMz%ConcurrentMultiSpanProcessor.shutdown*s  5566666rDrNrOcg}|jD]7}|j|j|}||8|dz }t j||\}}|rdS|D]}|durdSdS)aFCalls 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) rbrrrRrrrwaitr)r@rOrrrr timeout_sec done_futuresnot_done_futuress rArRz(ConcurrentMultiSpanProcessor.force_flush.s' # #B^**2>>JJF NN6 " " " "$s* )3);)@)@ [* * & &  5"  F}}%''uu(trD)rrSrTrUrVrW)rXrYrZr[r{r8r|r^rgrrmrr rr\r]rBrGrJrMr_rRr>rDrAr~r~s  M3.////@@C@@@@$ # $    7747777  (;;<       6:   $+d2       ????;;;;7777#$rDr~ceZdZd dededzddfdZedefdZedefdZee j de j fdZ dS) EventBaseNname timestampr<cP||_|t|_dS||_dSrS)_namer _timestamp)r@rrs rArgzEventBase.__init__Ms)  %iiDOOO'DOOOrDc|jSrSrrLs rArzEventBase.nameT zrDc|jSrS)rrLs rArzEventBase.timestampXs rDcdSrSr>rLs rA attributeszEventBase.attributes\s  rDrS)rXrYrZstrr^rgpropertyrrabcabstractmethodr3 Attributesrr>rDrArrLs((S(S4Z(4((((cX3X E,   X   rDrc eZdZdZddefdedejdedzdedzddf fd Z e dejfd Z e defd Z xZ S) EventaA 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<cZt||||_dSrS)superrg _attributes)r@rrrr __class__s rArgzEvent.__init__ms- y)))%rDc|jSrS)rrLs rArzEvent.attributesw rDcRt|jtr |jjSdSNr isinstancerrdroppedrLs rAdropped_attributeszEvent.dropped_attributes{) d&(9 : : ,#+ +qrD)rXrYrZr[(_DEFAULT_OTEL_SPAN_ATTRIBUTE_COUNT_LIMITrr3rr^rgrrr __classcell__rs@rArrbs(, $D &&&$&: & Tz &  &&&&&& E,   X CXrDrcfd}|S)Ncd}|j5|j |g|Ri|nd}dddn #1swxYwY|r"tdjdSdS)NFTz"Tried calling %s on an ended span.)rf _end_timeloggerwarningrX)r@rr already_endedrs rAwrapperz"_check_span_ended..wrappers Z % %~%T+D+++F++++ $  % % % % % % % % % % % % % % %  P NN? O O O O O P Ps .22r>)rrs` rA_check_span_endedrs( P P P P P NrDrrr<c@t|o|jp|p|jSrS)r_is_valid trace_staterrs rA_is_valid_linkrs, MW%L**K8K  rDceZdZdZddddddejjdeej dddf de dej dzdej dzde dzde jd eed eejd ejd edzd ededzdedzdedzddfdZedefdZedefdZedefdZede fdZdej dzfdZedZedejfdZedej dzfdZededzfdZededzfdZ edejfdZ!ede jfdZ"edeefdZ#edeejfd Z$ede fd!Z%ee&d"dedzfd#Z'ededzfd$Z(d,d&edzfd'Z)e*de de+e e ffd(Z,e*de jde+e e-fdzfd)Z.e*d eede/e+e e-ffd*Z0e*d eejde/e+e e-ffd+Z1dS)-rHzProvides 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<c||_||_||_| |_| |_||_| |_| |_||_||_ ||_ |tj i|_ n||_ | |_dSrS)r_context_kind_instrumentation_info_instrumentation_scope_parent _start_timerr_events_linksr!create _resource_status)r@rrrrrrrrrrrrrs rArgzReadableSpan.__init__s    %9"&;# %!%   %_R00DNN%DN rDcRt|jtr |jjSdSrrrLs rArzReadableSpan.dropped_attributesrrDcRt|jtr |jjSdSr)rrr'rrLs rAdropped_eventszReadableSpan.dropped_eventss& dlK 0 0 (<' 'qrDcRt|jtr |jjSdSr)rrr'rrLs rA dropped_linkszReadableSpan.dropped_linkss& dk; / / ';& &qrDc|jSrSrrLs rArzReadableSpan.namerrDc|jSrSrrLs rAget_span_contextzReadableSpan.get_span_contexts }rDc|jSrSrrLs rArzReadableSpan.contexts }rDc|jSrS)rrLs rArzReadableSpan.kindrrDc|jSrS)rrLs rArzReadableSpan.parent |rDc|jSrS)rrLs rArzReadableSpan.start_timerrDc|jSrSrrLs rArzReadableSpan.end_time ~rDc|jSrS)rrLs rArzReadableSpan.statusrrDc.t|jpiSrS)r rrLs rArzReadableSpan.attributess 0 6B777rDc*t|jSrS)r{rrLs rArzReadableSpan.eventssT\"""rDc*t|jSrS)r{rrLs rArzReadableSpan.linkssT[!!!rDc|jSrSrrLs rArzReadableSpan.resourcerrDzFYou should use instrumentation_scope. Deprecated since version 1.11.1.c|jSrS)rrLs rArz!ReadableSpan.instrumentation_infos ))rDc|jSrS)rrLs rArz"ReadableSpan.instrumentation_scopes **rDindentcd}|j!dtj|jj}d}|jrt j|j}d}|jrt j|j}dt|j j j i}|j j r|j j |d<|j |jr||jndt|j||||||j||j||jt/j|jd }t/j||S)N0x status_code description) rrr parent_idrrrrrrr)r)r trace_apiformat_span_idspan_idrr ns_to_iso_strrrrrrrrr_format_contextr_format_attributesr_format_eventsr _format_linksrjsonloadsrto_jsondumps)r@rrrrrf_spans rAr!zReadableSpan.to_json sa ; "LY5dk6IJJLLI   >+D,<==J > :)$.99H 3t|7<==  < # =$(L$z/ReadableSpan._format_events..Cs_      !/@@"55$      rDr>)rs rArzReadableSpan._format_eventsAs%        rDcd|DS)Ncg|]A}t|jt|jdBS)r)r:rrrr)r,links rAr.z.ReadableSpan._format_links..Psc     //L#55O       rDr>)rs rArzReadableSpan._format_linksNs%       rD)r)2rXrYrZr[rSpanKindINTERNALr1r2UNSETrr0r!r3rrrLinkr)r^r*rgrrrrrrrrrrrrrrrrrrrr! staticmethodr)rr rlistrrr>rDrArHrHs!15/3$('+"$*,#,#5#>;? 011!%#=A&-%,  T/  $  ' 2D8$J* 4d: BCX X sX cX)"7$">Xi(X -4X C$J   X #*X (X8E,888X8####X#"x /"""X"(XZP*&9D&@***X*+';d'B+++X+#1#1cDj#1#1#1#1J  c3h   \ $ c3h$ \  x  4S#X3G    \    Xin5  $tCH~:N    \    rDrHceZdZdZdZ ddedzdedzdedzdedzdedzd edzd edzd edzfd Zd Ze ddedzde dedzdedzfdZ dS) SpanLimitsa/ The 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 |||tt|_||tt |_||t} | | nt|_ ||t| | nt|_ ||t| | nt|_||t | | nt"|_||t&|_||t*|j|_dSrS)_from_env_if_absentr$_DEFAULT_OTEL_SPAN_EVENT_COUNT_LIMITr<r#_DEFAULT_OTEL_SPAN_LINK_COUNT_LIMITr=r#_DEFAULT_OTEL_ATTRIBUTE_COUNT_LIMITr;rrr>r)_DEFAULT_OTEL_EVENT_ATTRIBUTE_COUNT_LIMITr?r(_DEFAULT_OTEL_LINK_ATTRIBUTE_COUNT_LIMITr@rrArrB) r@r;r<r=r>r?r@rArBglobal_max_attributess rArgzSpanLimits.__init__sd22  ' 0   11  & /  !% 8 8 6! !  %0 " !4  $(#;#;  +)4&%= $ $  %)$<$< ,)4&%> % % !$(#;#;  +)4&%= $ $  %)$<$< -% % !*.)A)A % 2  % * * &&&rDct|jd|jd|jd|jd|jd|jd|jd|jdS) 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=)) typerXr>r?r@r;r<r=rArLs rA__repr__zSpanLimits.__repr__st**%MMD>@@I,,,t EI E E E !C!CDDD E 199W^^GU;;<< < s $A44.B")NNNNNNNNrS) rXrYrZr[r4r^rgrN classmethodrrDr>rDrAr9r9]s;((T E&*!% $*.+/*.+/04G G d G $JG : G !4Z G "Dj G !4ZG "DjG $':G G G G RMMMDH$J),7:Tz t[rDr9)r;r<r=r>r?r@rArBc$eZdZdZfdZdddddddejjeddde dfddde dej d ej dzd e j dzd dd edzd ejdeedzdeejdejdededzdedededzdegdfdzddf"fdZdZdZdeejfdZdej fdZd ee ejfddfdZde dejddfd Z e!d!e"ddfd"Z# d;de d ejd#e$dzddfd$Z%e!d%ejddfd&Z& dr:aSee `opentelemetry.trace.Span`. Users should create `Span` objects via the `Tracer` instead of this constructor. Args: name: The name of the operation this span represents context: The immutable span context parent: This span's parent's `opentelemetry.trace.SpanContext`, or None if this is a root span sampler: The sampler used to create this span trace_config: Unused. Originally intended for trace-level configuration from the OpenTelemetry protocol, but the upstream ``TraceConfig`` proto was removed. Retained for backwards compatibility. resource: Entity producing telemetry attributes: The span's attributes to be exported events: Timestamped events to be exported links: Links to other spans to be exported span_processor: `SpanProcessor` to invoke when starting and ending this `Span`. limits: `SpanLimits` instance that was passed to the `TracerProvider` cv|turtdt|S)Nz'Span must be instantiated via a tracer.)r: TypeErrorr__new__)rYrrrs rAr`z Span.__new__s1 $;;EFF Fwws###rDNr>T)record_end_metricsrrrsampler trace_configrrrrrrhrrecord_exceptionset_status_on_exceptionrrar<c v|tji}t|||| || |||_||_| |_||_| |_||_ tj |_ t|j j|d|j j|_||_|rO|D]L}t|j j|j|j j|_|j|M|| |_||_dS)N)rrrrrrrF) immutable max_value_lenrh)r!rrrg_sampler _trace_config_record_exception_set_status_on_exception_span_processor_limitsrdrerfrr>rBr _new_eventsrr?rrAr _new_linksr_record_end_metrics)r@rrrrbrcrrrrrrhrrdrelimitsrrar-rs rArgz Span.__init__$sQ*  r**H !5"7      )!1(?%- ^%% , L , ,@     ''))  + + +$5L5$"&,"C%%%!  ##E****ooe,, #5   rDcPt|jd|jd|jdS)Nz(name="z ", context=rL)rMrXrrrLs rArNz Span.__repr___s.t**%UUdjUUT]UUUUrDc4t|jjSrS)r'ror<rLs rArpzSpan._new_eventsbs4<2333rDcF|st|jjSg}|D]c}|r_t|j|jrEt |jj|j|jj|_ | |dtj |jj|S)Nri) r'ror=rrrrr@rArrfrom_seq)r@r valid_linksr1s rArqzSpan._new_linkses 7t|566 6  ) )D )t|T_EE )#4L4O"&,"C$$$ ""4(((#DL$:KHHHrDcJtjtj|jSrS)typingcastrr0rrLs rArzSpan.get_span_contextvs{90$-@@@rDc|j5|j(td ddddS|j|ddddS#1swxYwYdSNz Setting attribute on ended span.)rfrrrr _set_items)r@rs rAset_attributeszSpan.set_attributesysZ 4 4~)ABBB 4 4 4 4 4 4 4 4   ' ' 3 3 3  4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s#AAA#&A#keyrOc|j5|j(td ddddS||j|<ddddS#1swxYwYdSr})rfrrrr)r@rrOs rA set_attributezSpan.set_attributes Z * *~)ABBB * * * * * * * * %*D S !  * * * * * * * * * * * * * * * * * *s#A AAAr-c:|j|dSrS)rr)r@r-s rA _add_eventzSpan._add_events E"""""rDrct|jj||jj}|t |||dS)Nrirrr)rror?rArr)r@rrrs rA add_eventzSpan.add_eventsh ' L - ,;    %#        rDr1c:|j|dSrS)rr)r@r1s rA _add_linkzSpan._add_links 4     rDct||sdSt|jj||jj}|t j||dS)Nrir)rrror@rArrr5)r@rrs rAadd_linkz Span.add_links~ gz22  F& L , ,;    N%        rDct|j|j|j|j|j|j|j|j|j |j |j |j |j  S)N) rrrrrrrrrrrrr)rHrrrrrrrrrrrrrrLs rA_readable_spanzSpan._readable_spans^M<^'<+<'^!%!;"&"=    rDrr;c|j5|j(td ddddS||n t |_dddn #1swxYwY|j||dS)Nz"Calling start() on a started span.rq)rfrrrr rnrB)r@rr;s rAstartz Span.starts Z  +CDDD         )4 '))                   %%d>%JJJJJs#AAA"Arc|j5|jtd|j(td ddddS||n t |_d|j_dddn #1swxYwY|j r| |j ||j | dS)Nz$Calling end() on a not started span.zCalling end() on an ended span.T)rfr RuntimeErrorrrrr r _immutablerrrnrGrJr)r@rs rAendzSpan.ends= Z / /'"#IJJJ~)@AAA  / / / / / / / /*2)=XX799DN*.D  ' / / / / / / / / / / / / / / /  # '  $ $ & & & ''--- ##D$7$7$9$9:::::s9A=#A==BBc||_dSrSr)r@rs rA update_namezSpan.update_names  rDc|jduSrSrrLs rA is_recordingzSpan.is_recordings~%%rDrrct|trZ|jr|jjtjus|jtjurdS|td|||_dSt|trF|jr|jjtjus|tjurdSt|||_dSdS)NzJDescription %s ignored. Use either `Status` or `(StatusCode, Description)`) rr1rrr2OKr4rr)r@rrs rA set_statuszSpan.set_statuss ff % % 7  L, ==%)999&`"DLLL  + + 7  L, ==Z---!&+66DLLL 7 7rDexc_typeexc_valexc_tbcN|~|rj|jr||d|jrE|t t jt|j d|t |||dS)z3Ends context manager and calls `end` on the `Span`.NT) exceptionescapedz: )rr) rrlrdrmrr1r2ERRORrMrXr__exit__)r@rrrrs rArz Span.__exit__s  4#4#4#6#6 % G%%%FFF, $.$4(,W (>%K%K'%K%K 7F33333rDFrrc dtj|}t|j}t|j}|r |dkr|d|n|}t |tt|t|tt|i} |r| || d| |dS)z%Records an exception as a span event.r6builtins.rrN) join tracebackformat_exceptionrMrYrZr.r,rr-r+updater) r@rrrr stacktracemodulequalnameexception_typers rArdzSpan.record_exception(sWWY7 BBCC i+ ??/  J.. " " " " "  N s9~~ * s7|| B  +   z * * *        rD)NNrS)NNF)9rXrYrZr[r`rr2r3r8 _UnsetLimitsrr0r#Samplerr!r3rrrr5r)r_r*rrgrNrprqrrAttributeValuerrrrrr^rrrrHrr\r]rrrrr1r2rrM BaseExceptionr rrdrrs@rAr:r:s1.$$$$$04+/!$('+)-*,#,#5#>(5 ;?!%(,=A#96&9='96969696&96%, 96 !D( 96  96T/96$96$&96 '96 96&962D89696"&96" 4d:#96&%RX.5'96( )969696969696vVVV444I 8IIII"A)"7AAAA4!#u';";<4 4444**U-A*d****# #d#### (, $    $ :       &!in!!!!! (,   $       (     &"&59 K K$J K$+d2 K  K K K K;;C$J;$;;;;"&d&&&&#'77#74Z7  7777:4}%,4%4$ 4  4444446(, $     $ :             rDr:ceZdZdZdS)_SpanzProtected implementation of `opentelemetry.trace.Span`. This constructor exists to prevent the instantiation of the `Span` class by other mechanisms than through the `Tracer`. N)rXrYrZr[r>rDrArrEsrDrc0eZdZUeed<edZdS) _TracerConfig is_enabledc|dS)NTrr>)rYs rArQz_TracerConfig.defaultQssd####rDN)rXrYrZr_r|r\rQr>rDrArrMs;$$[$$$rDrceZdZdZddddejdedeezde de d e d e d e jdzd edzd dfdZdefdZded dfdZd efdZedejjddddddfdedejdzdejdejdeejdzde dzdededed e!ej"fdZ#dejjdddddfdedejdzdejdejdeejdzde dzdeded ej"fdZ$dS) Tracerz!See `opentelemetry.trace.Tracer`.Nmeter_provider_tracer_configrbrrh id_generatorr span_limitsrrrr<c ||_||_||_||_||_||_||_| pt|_ |ptj }t|tt|_dSrS)rbrrhrr _span_limitsrrrQr metrics_apiget_meter_providerr$r r_tracer_metrics) r@rbrrhrrrrrrs rArgzTracer.__init__Ys   ,($8!'&;#,G 0E0E0G0G'K;+I+K+K4  .8    rD tracer_configc||_dSrS)r)r@rs rA_set_tracer_configzTracer._set_tracer_configxs+rDc||_dSrS)r)r@rs rA _set_resourcezTracer._set_resource{s   rDc|jjS)zGIf the tracer is not enabled, start_span will create a NonRecordingSpan)rrrLs rA _is_enabledzTracer._is_enabled~s"--rDr>Trrrrrrrdre end_on_exitc #K|||||||||} tj| | ||5} | VddddS#1swxYwYdS)N)rrrrrrrdre)rrdre) start_spanruse_span) r@rrrrrrrdrerr9s rAstart_as_current_spanzTracer.start_as_current_spans!!-$;     #-$;      JJJ                   sA  AAc |pd}tj|} | )t| tjst d|stj| S| | jsd} |j } n| j } |j || ||||} | jr#tjtjjn"tjtjj} | |j } n | jj} | r&tj| tjjz} tj| |j d| | j}|j| | j}| jrYt9||| |j |j| j|j|||j |||j!|j"|}|#||ntj|}|S)Nr>z2parent_span_context must be a SpanContext or None.rF) is_remote trace_flagsr)rrrrbrrrhrrrrdrersrra)rr;)$rget_current_spanrrr0r_rNonRecordingSpanrrgenerate_trace_idr%rb should_sampledecision is_sampled TraceFlagsSAMPLEDDEFAULTis_trace_id_randomrrandom_trace_idRANDOM_TRACE_IDgenerate_span_idrrrrrrrrhrrrr)r@rrrrrrrdreparent_span_contextr%sampling_resultrr span_contextrar9s rArzTracer.start_spans '8         *: !64 4 *D !! K-6IJJJ J  &.A.J &"& (::< > >%i&:&BCC   &"/BBDDOO1=MO  #.i2BBK!,    . . 0 0#'3    "1<< !9    # 0 0 2 2 D$* *5#2%)%>!1(?(&*&A#5D" JJ*WJ E E E E-lCCCD rD)%rXrYrZr[r#rr!rar~r%r)r9r*r MeterProviderrrgrrr_rr4rr2r3rr\r]r3rrr5r^rr:rrr>rDrArrVs++<@/3   !  6 &'  "  2    4 $1D8 &,      >, ,,,,!h!4!!!!.T..../3#,#5#>'+13!%!%(, $t+  $   '$. $J"& ). !B/3#,#5#>'+13!%!%(,^^^$t+^ ^ $ ^  '$. ^$J^^"&^ ^^^^^^rDr tracer_scopecdtgt|S)zDefault Tracer Configurator implementation In order to update Tracers configs you need to call TracerProvider._set_tracer_configurator with a function implementing this interface returning a Tracer Config.rulesdefault_config)_RuleBasedTracerConfiguratorrrQrs rA_default_tracer_configuratorrs?  '$,,..     rDcRtgtd|S)NFrr)rrrs rA_disable_tracer_configuratorrs>  '$666     rDcNeZdZdZ d"ddddejdzdedzdedee zdzd e dzd e dzd e j dzd edzd dfdZd#dZdefdZed efdZded dfdZdefdZ d$dededzdedzdejdzd df dZded dfdZd#dZd%d ed efd!ZdS)&TracerProviderz)See `opentelemetry.trace.TracerProvider`.NT)r_tracer_configuratorrbrshutdown_on_exitactive_span_processorrrrrr<c |p t|_|t|_n||_|t ji|_n||_|stj}||_ |p t|_ tj td} | dk|_d|_||_|rt)j|j|_|pt.|_t3j|_i|_t;t<dr6t?j |j! d fd } t=j"| dSdS)Nr6truerr<c8x}r |dSdSrSr>)at_fork weak_at_forks rArz0TracerProvider.__init__.._after_in_childMs/*lnn,7GIIIIIrDrrV)#ra_active_span_processorr&rr!rrr#_get_from_env_or_defaultrbr9rr rSrrUrT _disabled_atexit_handler_meter_provideratexitregisterrMrrrdre _tracers_lock_tracersrrrr _handle_forkr) r@rbrrrrrrrdisabledrrs @rArgzTracerProvider.__init__ s " D%B%D%D #   1 3 3D   ,D   %_R00DNN%DN :799G '7:<<;0"55!))//11V;#-  B#)?4=#A#AD  ! @$@ !'^--<> 2) * * @"-d.?@@L         ? ? ? ? ? ? @ @rDcxtj|_|t dSrS)rdrer_update_resourcer"rLs rArzTracerProvider._handle_forkSs3&^-- =??@@@@@rDtracer_configuratorc||_|j5|jD]/\}}||}||0 ddddS#1swxYwYdS)zThis is the function used to update the TracerProvider TracerConfigurator Setting a new TracerConfigurator for a TracerProvider will update the TracerConfig of all Tracers create by this TracerProvider. N)rrritems_apply_tracer_configuratorr)r@rrtracerrs rA_set_tracer_configuratorz'TracerProvider._set_tracer_configuratorWs%8!   9 9151D1D1F1F 9 9-%v $ ? ?)!! ))-8888  9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9sA A''A+.A+c|jSrSr rLs rArzTracerProvider.resourcehrrDc|j5|j||_|jD]}||j ddddS#1swxYwYdSrS)rrmergervaluesr)r@rr s rArzTracerProvider._update_resourcels   5 5!^11(;;DN-..00 5 5$$T^4444 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5sAA,,A03A0rc ||S#t$r7td|tcYSwxYw)NzDFailed to create a Tracer Config for %s, using default Tracer config)r ExceptionrrrrQ)r@rs rAr z)TracerProvider._apply_tracer_configuratorrso +,,-BCC C + + +   V%   !((** * * *  +s>AAinstrumenting_module_nameinstrumenting_library_version schema_urlrztrace_api.Tracerc |jrtS|sd}td|d}t ddt dt |||}t||||}|j5||j vr|j |cdddS| |}t|j |j |j|j||j||j| }||j |<dddn #1swxYwY|S)Nr6z+get_tracer called with missing module name.ignorezEYou should use InstrumentationScope. Deprecated since version 1.11.1.zopentelemetry.sdk.trace)messagecategoryrr)rr/rerrorrDeprecationWarningr)r*rrr rrbrrrrr) r@rrrrrrrr s rA get_tracerzTracerProvider.get_tracer~s > << ( H(* % LLF G G G ( 0,. ) X',      3 % )    !5 % )   ! !   : :$ 55}%:; : : : : : : : :!;;%M  +!$!%#3,   F4:DM/ 0% : : : : : : : : : : : : : : :( s:C>AC>>DDrhc:|j|dS)zRegisters a new :class:`SpanProcessor` for this `TracerProvider`. The span processors are invoked in the same order they are registered. N)rrmrls rArmz!TracerProvider.add_span_processors! #66~FFFFFrDc|j|j"tj|jd|_dSdS)z;Shut down the span processors added to the tracer provider.N)rrMrr unregisterrLs rArMzTracerProvider.shutdownsJ #,,...   +  d2 3 3 3#'D  , +rDrNrOc6|j|S)aRequests 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. )rrRrQs rArRzTracerProvider.force_flushs$*66~FFFrD)NNTNNNrV)NNNrW) rXrYrZr[r#rr!r_rar~r%r9rr_TracerConfiguratorTrgrr rrrr*r rr3rrr8rmrMr^rRr>rDrArrsb33,0$(!%+/)-1@<@<@1@1@1@!D(1@T/1@ 1@ = & '   1@"D(1@ $&1@$1D81@3T91@ 1@1@1@1@fAAAA9&:9999"(X55d5555 +%9 + + + +59!%.2 99#&9(+Tz9$J 9 $t+ 9  9999vGG4GGGG((((GG#G$GGGGGGrDr)xrrconcurrent.futuresrrloggingrrdrrzrcollections.abcrrrrr dataclassesrr timer r3r r r warningsrtyping_extensionsr opentelemetryrr\rrrropentelemetry.attributesropentelemetry.sdkr'opentelemetry.sdk.environment_variablesrrrrrrrrrr1opentelemetry.sdk.environment_variables._internalr opentelemetry.sdk.resourcesr!r"opentelemetry.sdk.tracer#'opentelemetry.sdk.trace._tracer_metricsr$$opentelemetry.sdk.trace.id_generatorr%r&opentelemetry.sdk.utilr'$opentelemetry.sdk.util._configuratorr(&opentelemetry.sdk.util.instrumentationr)r*5opentelemetry.semconv.attributes.exception_attributesr+r,r-r.opentelemetry.tracer/r0opentelemetry.trace.statusr1r2opentelemetry.utilopentelemetry.util._decoratorr4 getLoggerrXrrGrrHrIrErFrVr8rar~ABCrrrrr_rrHr9r4rrDSPAN_ATTRIBUTE_COUNT_LIMITr:rrrr rrrrr>rDrAr<s!     "!!!!!11111111$#####((((((000000000000,,,,,,666666""""""                        -,,,,,IIIIIIOOOOOOOO......FFFFFF 8777777799999999$$$$$$AAAAAA  8 $ $&)#+.(,/)+.('*$&)#::::::::~FFFFFMFFFRggggg=gggT        ,I@   KU5E$ C C C C C C C C LSSSSSSSSlz#"(#)"(#)(.    (;;#,| | | | | 9><| | | ~ D $$$$$$$ $iiiiiY iiiX !5 6 EF4]C &     &GGGGGY-GGGGGrD