g :ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZmZddlmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZ dd lm!Z"dd l#m$Z$dd l%m&Z&dd l'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0dd l1m2Z2ddl3m4Z4ddl5m6Z6m7Z7ddl8m9Z9ddl:m;Z;mZ>m?Z?m@Z@mAZAddlBmCZCmDZDddlEmFZFmGZGddlHm Z ddlImJZJejeLZMdZNdZOdZPdZQdZRdZSdZTGddZUGddeUZVGddeUZWGdd ejZYGd!d"eYZZd#Z[d$eDd%e jd&e]fd'Z^Gd(d)Z_Gd*d+Z`e`e`je`je`je`je`je`je`je`j,Zbe`jde-eOZdGd-d.e"je_ZeGd/d0eeZfGd1d2e"jZgGd3d4e"jZhy)5N)environ)time_ns)MappingProxyType TracebackType) AnyCallableDictIteratorListMutableMappingOptionalSequenceTupleTypeUnion)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)_agnosticcontextmanagercdeZdZdZ d dddeej ddfdZd dZdd Z dd e de fd Z y) 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_contextreturncy)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. Nselfr7r9s U/var/www/openai/venv/lib/python3.12/site-packages/opentelemetry/sdk/trace/__init__.pyon_startzSpanProcessor.on_startdcy)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<r>r7s r?on_endzSpanProcessor.on_endsrArBcy)zJCalled when a :class:`opentelemetry.sdk.trace.TracerProvider` is shutdown.Nr<r>s r?shutdownzSpanProcessor.shutdown}rArBtimeout_milliscy)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. Nr<r>rIs r? force_flushzSpanProcessor.force_flushrArBNr7 ReadableSpanr:Nr:Ni0u) __name__ __module__ __qualname____doc__r context_apiContextr@rErHintboolrLr<rBr?r6r6[sV9=    !!4!45      Y  #  $  rBr6ceZdZUdZeedfed<dZdeddfdZ dd d d e e jddfd Z dd Z ddZddedefdZy)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|_y)Nr<)r\ threadingLock_lockrGs r?__init__z&SynchronousMultiSpanProcessor.__init__s!#^^% rBspan_processorr:Ncr|j5|xj|fz c_dddy#1swYyxYwz:Adds a SpanProcessor to the list handled by this instance.Nr`r\r>rbs r?add_span_processorz0SynchronousMultiSpanProcessor.add_span_processor' ZZ  ! !n%6 6 !ZZ-6r7r8r9cL|jD]}|j||y)Nr9)r\r@)r>r7r9sps r?r@z&SynchronousMultiSpanProcessor.on_starts$ ''B KK^K <(rBcH|jD]}|j|yrM)r\rE)r>r7rls r?rEz$SynchronousMultiSpanProcessor.on_ends''B IIdO(rBcF|jD]}|jy)z7Sequentially shuts down all underlying span processors.N)r\rH)r>rls r?rHz&SynchronousMultiSpanProcessor.shutdowns''B KKM(rBrIct|dzz}|jD],}t}||k\ry|j||z dzr,yy)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)rr\rL)r>rI deadline_nsrlcurrent_time_nss r?rLz)SynchronousMultiSpanProcessor.force_flushsUi.7":: ''B%iO+->>;#@W"LM (rBrMrNrPrQ)rRrSrTrUrr6__annotations__rargr rVrWr@rErHrXrYrLr<rBr?r[r[sM3.//& 77479===!!4!45=  = #$rBr[ceZdZdZddefdZdeddfdZdeeged fd e d e fd Z dd dde e jddfdZddZddZddedefdZy)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_threadscd|_tj|_tj j ||_y)Nr<) max_workers)r\r^r_r` concurrentfuturesThreadPoolExecutor _executor)r>rus r?raz%ConcurrentMultiSpanProcessor.__init__s:!#^^% #++>>#? rBrbr:Ncr|j5|xj|fz c_dddy#1swYyxYwrdrerfs r?rgz/ConcurrentMultiSpanProcessor.add_span_processorrhrifunc).Nargskwargscg}|jD]9}|jj||g|i|}|j|;|D]}|j yrM)r\r{submitappendresult)r>r}r~rryrlfutures r?_submit_and_awaitz.ConcurrentMultiSpanProcessor._submit_and_awaits^ ''B*T^^**48EdEfEF NN6 "(F MMOrBr7r8r9c.|jd||y)Nc|jSrM)r@rls r?z7ConcurrentMultiSpanProcessor.on_start..sr{{rBrkrr=s r?r@z%ConcurrentMultiSpanProcessor.on_starts  "D  rBc*|jd|y)Nc|jSrM)rErs r?rz5ConcurrentMultiSpanProcessor.on_end..s"))rBrrDs r?rEz#ConcurrentMultiSpanProcessor.on_ends 3T:rBc(|jdy)z6Shuts down all underlying span processors in parallel.c|jSrM)rHrs r?rz7ConcurrentMultiSpanProcessor.shutdown..s"++rBNrrGs r?rHz%ConcurrentMultiSpanProcessor.shutdowns 56rBrIc g}|jD]9}|jj|j|}|j |;|dz }t j j||\}}|ry|D]}|jryy)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) r\r{rrLrrxrywaitr)r>rIryrlr timeout_sec done_futuresnot_done_futuress r?rLz(ConcurrentMultiSpanProcessor.force_flushs''B^^**2>>>JF NN6 "(%s* )3););)@)@ [* & & "F==?#rB)rMrNrPrQ)rRrSrTrUrXrar6rgrrrr rVrWr@rErHrYrLr<rBr?rtrts  C 7747  (;;<    9=  !!4!45    ;7#$rBrtceZdZd dedeeddfdZedefdZedefdZ ee jde jfdZy) EventBaseNname timestampr:cD||_|t|_y||_yrM)_namer _timestamp)r>rrs r?razEventBase.__init__&s  %iDO'DOrBc|jSrMrrGs r?rzEventBase.name- zzrBc|jSrM)rrGs r?rzEventBase.timestamp1s rBcyrMr<rGs r? attributeszEventBase.attributes5s rBrM)rRrSrTstrr rXrapropertyrrabcabstractmethodr1 Attributesrr<rBr?rr%s(S(Xc](d(c3 E,,  rBrc eZdZdZddefdedejdee dee ddf fd Z e dejfd Z e de fd Z xZS) 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:c4t|||||_yrM)superra _attributes)r>rrrr __class__s r?razEvent.__init__Fs y)%rBc|jSrM)rrGs r?rzEvent.attributesPrBcdt|jtr|jjSyNr isinstancerrdroppedrGs r?dropped_attributeszEvent.dropped_attributesT( d&&(9 :##++ +rB)rRrSrTrU(_DEFAULT_OTEL_SPAN_ATTRIBUTE_COUNT_LIMITrr1rr rXrarrr __classcell__rs@r?rr;s(,#'G &&$$&C= & } &  & E,,  CrBrcfd}|S)Ncd}|j5|j |g|i|nd}ddd|r!tjdjyy#1swY-xYw)NFTz"Tried calling %s on an ended span.)r` _end_timeloggerwarningrR)r>r~r already_endedr}s r?wrapperz"_check_span_ended..wrapper\sZ ZZ~~%T+D+F+ $   NN? O  Zs AA!r<)r}rs` r?_check_span_endedr[s P NrBrrr:cXt|xr|jxs|xs |jSrM)rYis_valid trace_staterrs r?_is_valid_linkrjs- MW%%L**K8K8K rBc8eZdZdZddddddej j deejdddf de de ejde ejde e dejd eed eej$d ej d e ed ede ede ede eddfdZedefdZedefdZedefdZede fdZdZedZedej fdZede ejfdZede efdZ ede efdZ!edejfdZ"edejfdZ#edeefdZ$edeej$fd Z%ede fd!Z&ee'd"d#$de efd%Z(ede efd&Z)d-d'efd(Z*e+de de,e e ffd)Z-e+dejde e,e e.ffd*Z/e+d eede0e,e e.ffd+Z1e+d eej$de0e,e e.ffd,Z2y).rOzProvides 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||_||_||_| |_| |_||_| |_| |_||_||_ ||_ |"tji|_ | |_y||_ | |_yrM)r_context_kind_instrumentation_info_instrumentation_scope_parent _start_timerr_events_linksr"create _resource_status)r>rrrrrrrrrrrrrs r?razReadableSpan.__init__xs    %9"&;# %!%   %__R0DN &DN rBcdt|jtr|jjSyrrrGs r?rzReadableSpan.dropped_attributesrrBcdt|jtr|jjSyr)rrr&rrGs r?dropped_eventszReadableSpan.dropped_eventss# dllK 0<<'' 'rBcdt|jtr|jjSyr)rrr&rrGs r? dropped_linkszReadableSpan.dropped_linkss# dkk; /;;&& &rBc|jSrMrrGs r?rzReadableSpan.namerrBc|jSrMrrGs r?get_span_contextzReadableSpan.get_span_context }}rBc|jSrMrrGs r?rzReadableSpan.contexts }}rBc|jSrM)rrGs r?rzReadableSpan.kindrrBc|jSrM)rrGs r?rzReadableSpan.parent ||rBc|jSrM)rrGs r?rzReadableSpan.start_timerrBc|jSrMrrGs r?rzReadableSpan.end_time ~~rBc|jSrM)rrGs r?rzReadableSpan.statusrrBc4t|jxsiSrM)rrrGs r?rzReadableSpan.attributess 0 0 6B77rBc:td|jDS)Nc3 K|]}|ywrMr<).0events r? z&ReadableSpan.events..s5 uU  )tuplerrGs r?rzReadableSpan.eventss5 555rBc:td|jDS)Nc3 K|]}|ywrMr<)rlinks r?rz%ReadableSpan.links..s2kdTkr)rrrGs r?rzReadableSpan.linkss2dkk222rBc|jSrMrrGs r?rzReadableSpan.resourcerrBz1.11.1z$You should use instrumentation_scope)versionreasonc|jSrM)rrGs r?rz!ReadableSpan.instrumentation_infos )))rBc|jSrM)rrGs r?rz"ReadableSpan.instrumentation_scopes***rBindentcd}|j,dtj|jj}d}|jrt j |j}d}|jrt j |j}dt|jjji}|jjr|jj|d<|j|jr|j|jndt|j |||||j#|j$|j'|j(|j+|j,t/j0|j2j5d }t/j6||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 r?rzReadableSpan.to_jsonsb ;; "Y55dkk6I6IJKLI   ++D,<,<=J >>))$..9H 3t||77<<=  << # #$(LL$<$#>>B 0 01$("&@D)//0../  8$  $$  '  '':;SM3- ((<= BC  s ci((!6!67 HSM  (3- ((8E,,886663x /33(!G*h/B&C**+x0D'E++#1c#1J  c3h  $$ $sCx. !  x  4S#X3G      Xinn5  $tCH~:N    rBrOceZdZdZdZ ddeedeedeedeedeed eed eed eefd Zd Ze ddeede deedeefdZ y) 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 (|j|tt|_|j|tt |_|j|t} | | nt|_ |j|t| | nt|_ |j|t| | nt|_|j|t | | nt"|_|j|t&|_|j|t*|j(|_yrM)_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+rr,rr-) r>r&r'r(r)r*r+r,r-global_max_attributess r?razSpanLimits.__init__cs-22  ' 0  11  & / !% 8 8 6!  %0 "4  $(#;#;  +)4&= $  %)$<$< ,)4&> % !$(#;#;  +)4&= $  %)$<$< -% !*.)A)A % 2  % % * &rBct|jd|jd|jd|jd|j d|j d|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=)) typerRr)r*r+r&r'r(r,rGs r?__repr__zSpanLimits.__repr__st*%%&&;D>@I,, EI 19W^^GU;< <  E !CDD Es  B %B.)NNNNNNNNrM) rRrSrTrUr r rXrar9 classmethodrr/r<rBr?r$r$6s(T E)-$(#'-1.2-1.237G   G SMG C= G &c] G 'sm G &c]G 'smG $,C=G RMJNSM,/:B3- #rBr$)r&r'r(r)r*r+r,r-c!eZdZdZfdZdddddddej jeddde dfde dejde ejd e e jd dd e ed ej"d e eedeej(dej dede ededede eddf fd ZdZdZdeej(fdZdZd ee ej<fddfdZde dej<ddfdZ e!de"ddfd Z# d8de d ej"d!e e$ddfd"Z%e!d#ej(ddfd$Z& d9de d ej"ddfd%Z'de(fd&Z) d8d'e e$d(e e*jVddfd)Z,d9d*e e$ddfd+Z-e!de ddfd,Z.defd-Z/e! d9d.e0jbe2e3fd/e0je ddfd0Z4d1e e5e6d2e e6d3e e7ddffd4 Z8 d:d5e6d ej"d!e e$d6eddf d7Z9xZ:S);r8a3See `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: TODO 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` cH|tur tdt| |S)Nz'Span must be instantiated via a tracer.)r8 TypeErrorr__new__)rDr~rrs r?rKz Span.__new__s% $;EF Fws##rBNr<Trrrsampler trace_configrrrrrrbrrecord_exceptionset_status_on_exceptionrr:c |tji}t| |||| || |||_||_| |_||_| |_||_ tj|_ t|jj|d|jj|_|j#|_|rg|D]b}t|jj&|j(|jj*|_|j$j-|d|j/| |_y)N)rrrrrrrF) immutable max_value_lenrR)r"rrra_sampler _trace_config_record_exception_set_status_on_exception_span_processor_limitsr^r_r`rr)r-r _new_eventsrr*rr,r _new_linksr)r>rrrrLrMrrrrrrbrrNrOlimitsrrrs r?raz Span.__init__s &  r*H !5"7    )!1(?%- ^^% , LL , , ,,@@   '') $5LL55$$"&,,"C"C%!  ##E*  ooe, rBcft|jd|jd|jdS)Nz(name="z ", context=r7)r8rRrrrGs r?r9z Span.__repr__2s/t*%%&gdjj\T]]OSTUUrBc@t|jjSrM)r&rYr'rGs r?rZzSpan._new_events5s4<<2233rBc|st|jjSg}|D]|}|st|j|j s't |jj|j |jj|_ |j|~tj|jj|S)NrS) r&rYr(rrrrr+r,rrfrom_seq)r>r valid_linksrs r?r[zSpan._new_links8st||556 6 Dt||T__E#4LL44OO"&,,"C"C$ ""4(##DLL$:$:KHHrBc|jSrMrrGs r?rzSpan.get_span_contextIrrBc|j5|jtjd dddy|j D]\}}||j |< dddy#1swYyxYw)Nz Setting attribute on ended span.)r`rrritemsr)r>rkeyr:s r?set_attributeszSpan.set_attributesLs_ZZ~~)ABZ )..0 U(-  %1 ZZs#A*'A**A3rer:c(|j||iSrM)rf)r>rer:s r? set_attributezSpan.set_attributeWs""C<00rBrc:|jj|yrM)rr)r>rs r? _add_eventzSpan._add_eventZs E"rBrct|jj||jj}|j t |||y)NrSrrr)rrYr*r,rjr)r>rrrs r? add_eventzSpan.add_event^sJ ' LL - - ,,;;  %#  rBrc:|jj|yrM)rr)r>rs r? _add_linkzSpan._add_linkqs 4 rBct||syt|jj||jj}|j t j||y)NrSr)rrrYr+r,rorr!)r>rrs r?add_linkz Span.add_linkusX gz2 & LL , , ,,;;  NN%  rBc6t|j|j|j|j|j |j |j|j|j|j|j|j|j S)N) rrrrrrrrrrrrr)rOrrrrrrrrrrrrrrGs r?_readable_spanzSpan._readable_spansrMM<<^^''<<++<<''^^!%!;!;"&"="=  rBrr9c|j5|jtjd dddy||n t |_ddd|j j ||y#1swY'xYw)Nz"Calling start() on a started span.rk)r`rrrrrXr@)r>rr9s r?startz Span.startsl ZZ+CDZ )4 ')    %%d>%JZs#A2A22A;rcB|j5|j td|jtj d dddy||n t |_ddd|jj|jy#1swY3xYw)Nz$Calling end() on a not started span.zCalling end() on an ended span.) r`r RuntimeErrorrrrrrXrErs)r>rs r?endzSpan.ends ZZ'"#IJJ~~)@A Z*2)=X79DN ##D$7$7$9:Zs:BBBc||_yrMr)r>rs r? update_namezSpan.update_names  rBc|jduSrMrrGs r? is_recordingzSpan.is_recordings~~%%rBrrct|tro|jr&|jjtj us|jtj ury|tjd|||_yt|trW|jr&|jjtj us|tj uryt|||_yy)NzJDescription %s ignored. Use either `Status` or `(StatusCode, Description)`) rr/rrr0OKr rr)r>rrs r? set_statuszSpan.set_statuss ff % LL,, =%%)9)99&`"DL  + LL,, =Z---!&+6DL,rBexc_typeexc_valexc_tbc|t|jrd|jr|j|d|jr9|j t t j|jd|t|)|||y)z3Ends context manager and calls `end` on the `Span`.NT) exceptionescapedz: )rr) r|rVrNrWrr/r0ERRORrRr__exit__)r>rrrrs r?rz Span.__exit__s  4#4#4#6%%%%%F,,$.$4$4'/'8'8&9G9$E 7F3rBrrc djtjt|||j}t|j }t|j }|r |dk7r|d|n|}t|tt|t|tt|i} |r| j||jd| |y)z%Records an exception as a span event.r4)r:tbbuiltins.rrlN)join tracebackformat_exceptionr8 __traceback__rSrTr,r*rr+r)updaterm) r>rrrr stacktracemodulequalnameexception_typers r?rNzSpan.record_exceptionsWW  & &YyY5L5L  i++ ?//&J.haz "  N s9~ * s7| B    z *    rB)NNrM)NNF);rRrSrTrUrKrrrr6 _UnsetLimitsrr.r r#Samplerr"r1rrrr!r'rYr(rar9rZr[rr AttributeValuerfrhrrrjrXrmrorqrOrsrVrWrurxrzr|typingrr/r0rr BaseExceptionrrrNrrs@r?r8r8s*$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-nV4I 8I" .sE$8$889 .  .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=      rBr8ceZdZdZy)_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)rRrSrTrUr<rBr?rrsrBrc,eZdZdZdej dedeee fde de de de d d fd Zed ej"j$d d d d d d fdedeej,dej"dej0deeej4deedededed eej<fdZd ej"j$d d d d d fdedeej,dej"dej0deeej4deededed ej<fdZ y )Tracerz!See `opentelemetry.trace.Tracer`.rLrrb id_generatorr span_limitsrr:Ncf||_||_||_||_||_||_||_yrM)rLrrbrr _span_limitsr)r>rLrrbrrrrs r?razTracer.__init__s:   ,($8!'&;#rBr<TrrrrrrrNrO end_on_exitc #K|j||||||||} tj| | ||5} | dddy#1swYyxYww)N)rrrrrrrNrO)rrNrO) start_spanruse_span) r>rrrrrrrNrOrr7s r?start_as_current_spanzTracer.start_as_current_span3sh!!-$;     #-$;  J    s3AA AA Ac  tj|j} | %t| tjs t d| | j sd} |jj} n | j} |jj|| ||||} | jjr-tjtjjn,tjtjj } tj| |jj#d| | j$} | jj'rt)|| | |j|j*| j,j/|j0|||j2|||j4|j6}|j9|||Stj:| }|S)Nz2parent_span_context must be a SpanContext or None.F) is_remote trace_flagsr)rrrrLrrrbrrrrNrOr\r)rr9r)rget_current_spanrrr.rJrrgenerate_trace_idrrL should_sampledecision is_sampled TraceFlagsSAMPLEDDEFAULTgenerate_span_idrr|rrrcopyrbrrrruNonRecordingSpan)r>rrrrrrrNrOparent_span_contextrsampling_resultr span_contextr7s r?rzTracer.start_spanRs(88       *: !6!64 D   &.A.J.J"& ((::%%i&:&:&B&BC  !,,     . . 0#'33    # # 0 0 2$* *55::<#22%)%>%>!1(?((&*&A&AD JJ*WJ E --lCD rB)!rRrSrTrUr#rr"rr[rtr$r'r$r(rar2rrrrr rVrWr1rrr!rXrYr r8rrr<rBr?rrs+<!!<< )+G G <"<2< < 4< <(26#,#5#5#>#>'+46$(!%(, +--.   $$  01 SM"& ).. !B26#,#5#5#>#>'+46$(!%(,JJ+--.J  J $$ J 01 JSMJJ"&J JrBrc>eZdZdZ ddeej deedede e e dfdee dee d dfd Zed efd Z dd ed ejedejedejej(d df dZded dfdZdZdded efdZy)TracerProviderz)See `opentelemetry.trace.TracerProvider`.NrLrshutdown_on_exitactive_span_processorrrr:c|xs t|_|t|_n||_|t j i|_n||_|stj}||_ |xs t|_ tjtd}|jj!dk(|_d|_|r%t'j(|j*|_yy)Nr4true)r[_active_span_processorr%rr"rrr#_get_from_env_or_defaultrLr$rrr>rr@r? _disabled_atexit_handleratexitregisterrH)r>rLrrrrrdisableds r?razTracerProvider.__init__s " D%B%D #   1 3D  ,D   %__R0DN%DN779G '7:<;;0"5!)//1V;# #)??4==#AD  rBc|jSrMrrGs r?rzTracerProvider.resourcerrBinstrumenting_module_nameinstrumenting_library_version schema_urlrztrace_api.Tracercp|jrtjdtS|sd}tj d|d}t ddt dt|||}t|j|j|j|j||jt||||S)NzSDK is disabled.r4z+get_tracer called with missing module name.ignorezoCall to deprecated method __init__. \(You should use InstrumentationScope\) -- Deprecated since version 1.11.1.zopentelemetry.sdk.trace)messagecategoryr)rrrr-errorrDeprecationWarningr'rrLrrrrr()r>rrrrrs r? get_tracerzTracerProvider.get_tracers >> NN- .< ((* % LLF G ( 0,. ) N(,  3 % )    LL MM  ' '       )-    rBrbc:|jj|y)zRegisters a new :class:`SpanProcessor` for this `TracerProvider`. The span processors are invoked in the same order they are registered. N)rrgrfs r?rgz!TracerProvider.add_span_processors ##66~FrBc|jj|j'tj|jd|_yy)z;Shut down the span processors added to the tracer provider.N)rrHrr unregisterrGs r?rHzTracerProvider.shutdownsA ##,,.    +   d22 3#'D  ,rBrIc8|jj|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. )rrLrKs r?rLzTracerProvider.force_flushs$**66~FFrB)NNTNNN)NNNrQ)rRrSrTrUr r#rr"rYrr[rtr$r$rarrrrr1rrr6rgrHrXrLr<rBr?rrsF3/3'+!% .2,0B(**+B8$B B % )+G M B{+Bj)B BB( ?C+/8< - #&- (.s';- OOC( - OOE$4$45 -  - ^GG4G(G#G$GrBr)irrconcurrent.futuresrxrloggingr^rrosrtimerr1rrrrr r r r r rrrrwarningsrr opentelemetryrrVrropentelemetry.attributesropentelemetry.sdkr'opentelemetry.sdk.environment_variablesrrrrrrrr 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.statusr/r0opentelemetry.utilopentelemetry.util._decoratorr2 getLoggerrRrr2rr3r4r0r1rAr6r[rtABCrrrrrYrrOr$r rr/SPAN_ATTRIBUTE_COUNT_LIMITr8rrrr<rBr?rs    1    $!0,6"   1,O. 89$A   8 $&)#+.(,/)+.('*$&)#/ / h=M=@S=Sl  ,I@ KU5E5E$ C C LSSl##"((#))"((#))(..  (;;#,r 9>><r j D@Y  @FzGY--zGrB