Uvh ddlmZddlZddlZddlmZmZmZddlmZddl Z ddl m Z m Z m Z ddlmZddlmZmZmZmZmZddlmZerdd lmZmZmZdd lmZdd lmZdd lmZdd lmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddl&m'Z'm(Z(e"dZ)e%dZ*ddlm+Z+ddl,m-Z-ddl.m/Z/m0Z0m1Z1m2Z2Gdde'dZ3Gdde3dZ4e'd d!e5iZ6d"Z7d#Z8Gd$d%e5eZ9e9jtgZ;e9jxe9jxe9jxe9jze9jte9jxe9jze9jze9jzd& Z>d'Z?Gd(d)Z@Gd*d+ZAGd,d-eAZBGd.d/eAZCere!d6d0ZDe!d1ZDd6d2ZDdd3lEmFZFmGZGmHZHmIZImJZJmKZKej5ejd4eNdd5lOmPZPdddy#1swYyxYw)7)DecimalN)datetime timedeltatimezone)Enum) INSTRUMENTER SPANSTATUSSPANDATA)get_profiler_id)get_current_thread_metais_valid_sample_rateloggernanosecond_timeshould_be_treated_as_error) TYPE_CHECKING)CallableMappingMutableMapping)Any)Dict)Iterator)List)Optional)overload) ParamSpec)Tuple)Union)TypeVar) TypedDictUnpackPR)ContinuousProfile)Profile)EventMeasurementUnitSamplingContextMeasurementValueceZdZUeed< eed< eed< eed< eed< eed< eed< eded < eed < ed ed < eeee fed < ded< eed< eed<y) SpanKwargstrace_idspan_idparent_span_idsame_process_as_parentsampledop descriptionzsentry_sdk.Hubhubstatus Transactioncontaining_transactionstart_timestampzsentry_sdk.ScopescopeoriginnameN) __name__ __module__ __qualname__str__annotations__boolrrrfloatM/opt/face_recognition/venv/lib/python3.12/site-packages/sentry_sdk/tracing.pyr*r*0s   T< $$J    Y & ''s r ( 778!%%"899 "!X   `rBr*F)totalc0eZdZUeed< eed< ded<y)TransactionKwargssourceparent_sampledBaggagebaggageN)r:r;r<r=r>r?rArBrCrFrFks   PrBrFProfileContext profiler_idrJz sentry-tracec*eZdZdZdZdZdZdZdZdZ y) TransactionSource componentcustomroutetaskurlviewc|jSN)valueselfs rC__str__zTransactionSource.__str__s zzrBN) r:r;r< COMPONENTCUSTOMROUTETASKURLVIEWrZrArBrCrNrNs%I F E D C DrBrN) endpoint function_name handler_namemethod_and_path_patternpath route_name route_pattern uri_templaterSc\|dkrtjSd|cxkrdkrnn|dk(rtjS|dk(rtjS|dk(rtjS|dk(rtj S|dk(rtj S|dk(rtjStjSd|cxkrd krantjS|d k(rtjS|d k(rtjS|d k(rtjStjStjS) z Returns the Sentry status corresponding to the given HTTP status code. See: https://develop.sentry.dev/sdk/event-payloads/contexts/#trace-context iiiiiiiiiXiii)r OKPERMISSION_DENIED NOT_FOUNDRESOURCE_EXHAUSTEDFAILED_PRECONDITIONUNAUTHENTICATEDALREADY_EXISTSINVALID_ARGUMENTDEADLINE_EXCEEDED UNIMPLEMENTED UNAVAILABLEINTERNAL_ERROR UNKNOWN_ERROR)http_status_codes rCget_span_status_from_http_coderxs#}}  &3 & s "// /  $'' '  $00 0  $11 1  $-- -  $,, ,.. .  &3 &  # ## s "// /  $++ +  $)) ),, ,  # ##rBc eZdZdZdZdZdZy) _SpanRecorderz5Limits the number of spans recorded in a transaction.maxlenspans dropped_spansc4|dz |_g|_d|_y)Nrr{rYr|s rC__init__z_SpanRecorder.__init__sqj  rBct|j|jkDrd|_|xjdz c_y|jj |y)Nr)lenr}r|_span_recorderr~append)rYspans rCaddz_SpanRecorder.addsA tzz?T[[ ("&D    ! #  JJ  d #rBN)r:r;r<__doc__ __slots__rrrArBrCrzrzs?4I $rBrzc$eZdZdZdZ d!dZdZdZdZdZ d Z e d Z e jfd Zed Zedd dZdZedZdZdZdZdZdZdZd"dZdZdZdZdZd#dZ dZ!dZ"dZ#d Z$y)$SpanakA span holds timing information of a block of code. Spans can have multiple child spans thus forming a span tree. :param trace_id: The trace ID of the root span. If this new span is to be the root span, omit this parameter, and a new trace ID will be generated. :param span_id: The span ID of this span. If omitted, a new span ID will be generated. :param parent_span_id: The span ID of the parent span, if applicable. :param same_process_as_parent: Whether this span is in the same process as the parent span. :param sampled: Whether the span should be sampled. Overrides the default sampling decision for this span when provided. :param op: The span's operation. A list of recommended values is available here: https://develop.sentry.dev/sdk/performance/span-operations/ :param description: A description of what operation is being performed within the span. .. deprecated:: 2.15.0 Please use the `name` parameter, instead. :param name: A string describing what operation is being performed within the span. :param hub: The hub to use for this span. .. deprecated:: 2.0.0 Please use the `scope` parameter, instead. :param status: The span's status. Possible values are listed at https://develop.sentry.dev/sdk/event-payloads/span/ :param containing_transaction: The transaction that this span belongs to. :param start_timestamp: The timestamp when the span started. If omitted, the current time will be used. :param scope: The scope to use for this span. If not provided, we use the current scope. )r+r,r-r.r/r0r1 _measurementsr6_start_timestamp_monotonic_nsr3 timestamp_tags_datarr2_context_manager_state_containing_transaction_local_aggregatorr7r8r9_flags_flags_capacityNcv|xstjj|_|xs!tjjdd|_||_||_||_||_|xs||_ | |_ ||_ | |_ | |_ i|_i|_i|_| |_i|_d|_|;t)j*dt,d|jxs |j|_ | $t/j0t2j4} n4t7| t8r$t/j:| t2j4} | |_ t?|_ d|_"d|_#d|_$|jK|jMtOy#tB$rYJwxYw)N z>The `hub` parameter is deprecated. Please use `scope` instead. stacklevel)(uuiduuid4hexr+r,r-r.r/r0r1r3r2r7r8rrrrrrwarningswarnDeprecationWarningrnowrutc isinstancer@ fromtimestampr6rrAttributeErrorrrrupdate_active_threadset_profiler_idr )rYr+r,r-r.r/r0r1r2r3r5r6r7r8r9s rCrz Span.__init__s|$!4DJJL$4$4 7$**,"2"223"7 ,&<# .;     '=$ ! ? MMP"  0syyDJ  "&ll8<<8O  /&44_hllSO. 2A1BD . "!% !!# _./   sF,, F87F8c>|jt||_yyrV)rrzrs rCinit_span_recorderzSpan.init_span_recorderbs    &"/"7D  'rBcD|j}|tx}|_|SrV)rLocalAggregator)rYrvs rC_get_local_aggregatorzSpan._get_local_aggregatorgs'  # # :*9*; ;B' rBcd|jjd|jd|jd|jd|j d|j d|jd|jd S) N) __class__r:r0r1r+r,r-r/r8rXs rC__repr__z Span.__repr__nsP ''    ##    rBc|jxstj}|j}||_||f|_|SrV)r7 sentry_sdkget_current_scoperr)rYr7old_spans rC __enter__zSpan.__enter__~s; #>     ' ' VD,G,G,V,V     e $ rBc z|turtjdtjt |fi|S)a( Create a Transaction with the given params, then add in data pulled from the ``sentry-trace`` and ``baggage`` headers from the environ (if any) before returning the Transaction. This is different from :py:meth:`~sentry_sdk.tracing.Span.continue_from_headers` in that it assumes header names in the form ``HTTP_HEADER_NAME`` - such as you would get from a WSGI/ASGI environ - rather than the form ``header-name``. :param environ: The ASGI/WSGI environ to pull information from. zXDeprecated: use Transaction.continue_from_environ instead of Span.continue_from_environ.)rrwarningr4continue_from_headersEnvironHeaders)clsenvironrs rCcontinue_from_environzSpan.continue_from_environs9& $; NN9 001HSFSSrB _sample_randc h|turtjdtj|j t |}|jt |it|j t}|!|j||jtdi|}d|_ |S)a Create a transaction with the given params (including any data pulled from the ``sentry-trace`` and ``baggage`` headers). :param headers: The dictionary with the HTTP headers to pull information from. :param _sample_rand: If provided, we override the sample_rand value from the incoming headers with this value. (internal use only) zXDeprecated: use Transaction.continue_from_headers instead of Span.continue_from_headers.rFrA) rrrrIfrom_incoming_headerrBAGGAGE_HEADER_NAMEupdateextract_sentrytrace_dataSENTRY_TRACE_HEADER_NAMEfreezer4r.)rheadersrrrJsentrytrace_kwargs transactions rCrzSpan.continue_from_headerss$ $; NN9 .. KK+ ,<   *G455 KK0 1   ) MM, - NN !+F+ -2 *rBc#K|jsyt|jf|jjj }|r t |fyyw)z Creates a generator which returns the span's ``sentry-trace`` and ``baggage`` headers. If the span's containing transaction doesn't yet have a ``baggage`` value, this will cause one to be generated and stored. N)r5rto_traceparent get_baggage serializer)rYrJs rC iter_headerszSpan.iter_headerssZ** &(;(;(===--99;EEG %w. . sAAc dtjd|sy|jt|ifi|S)a DEPRECATED: Use :py:meth:`sentry_sdk.tracing.Span.continue_from_headers`. Create a ``Transaction`` with the given params, then add in data pulled from the given ``sentry-trace`` header value before returning the ``Transaction``. zwDeprecated: Use Transaction.continue_from_headers(headers, **kwargs) instead of from_traceparent(traceparent, **kwargs)N)rrrr)r traceparentrs rCfrom_traceparentzSpan.from_traceparent$sC  A (s(( %{ 3 7=  rBc|jdurd}n|jdurd}nd}|jd|j}||d|z }|S)NT1F0-)r/r+r,)rYr/rs rCrzSpan.to_traceparent=sT <<4 G \\U "GG!% =   G- -KrBcP|jr|jjSy)zReturns the :py:class:`~sentry_sdk.tracing_utils.Baggage` associated with this ``Span``, if any. (Taken from the root of the span tree.) N)r5rrXs rC to_baggagezSpan.to_baggageLs%  & &..::< <rBc"||j|<yrV)rrYkeyrWs rCset_tagz Span.set_tagU 3rBc"||j|<yrV)rrs rCset_dataz Span.set_dataYrrBcht|j|jkr||j|<yyrV)rrr)rYflagresults rCset_flagz Span.set_flag]s, t{{ d22 2 &DKK  3rBc||_yrVr3rYrWs rCrzSpan.set_statusbs  rBc`tjdtd||d|j|<yz .. deprecated:: 2.28.0 This function is deprecated and will be removed in the next major release. zq`set_measurement()` is deprecated and will be removed in the next major version. Please use `set_data()` instead.rr)rWunitNrrrrrYr9rWrs rCset_measurementzSpan.set_measurementf0    .3D#A4 rBc|M|jtjt||!|jtj|yyyrV)rr THREAD_IDr= THREAD_NAMErY thread_id thread_names rC set_threadzSpan.set_threadtsF  MM(,,c)n =& h22K@' !rBcJ|!|jtj|yyrV)rr PROFILER_IDrYrLs rCrzSpan.set_profiler_id}s!  " MM(.. < #rBc|jdt||jtj||j t |y)Nzhttp.status_code)rr=rr HTTP_STATUS_CODErrxrY http_statuss rCset_http_statuszSpan.set_http_statuss@ K 0  h//= 6{CDrBc |jdk(S)NokrrXs rC is_successzSpan.is_successs{{d""rBc|jy |r> % 8mU3$,$:$:=(,,$WM!.)+d.P.PP!%!5!5 !(49" 7557*5$7  8%\\(,,7DN 8sA6B**1CCc h|j|j|j|j|j|j |j |j|jd }|jr|j|jd<|j!|jj}|r||d<t|jdkDr|j|d<|j}|r||d<i}|j|j |j|j"|r||d<|S)z5Returns a JSON-compatible representation of the span.) r+r,r-r.r0r1r6rr8r3_metrics_summaryr measurementstagsdata)r+r,r-r.r0r1r6rr8r3rrto_jsonrrrrr)rYrmetrics_summaryr"r#s rCr$z Span.to_jsons   ||"11&*&A&A''++#33kk   ;;#';;DJJx  ! ! -"44<<>O)8%& t!! "Q &!%!3!3B~ zz BvJ DKK  DJJ BvJ rBc|j|j|j|j|j|j d}|j r|j |d<|jr+|jjj|d<i}|jjtj}|||d<|jjtj}|||d<|r||d<|S)N)r+r,r-r0r1r8r3dynamic_sampling_contextz thread.idz thread.namer#)r+r,r-r0r1r8r3r5rr'rrr r r )rYrr#r r s rCget_trace_contextzSpan.get_trace_contexts ||"11''++kk   ;;;;BxL  & &++779RRT ) *JJNN8#5#56  )D jjnnX%9%9:  ""-D  BvJ rBcb|jjtj}|yd|iS)NrL)rrr rrs rCget_profile_contextzSpan.get_profile_contexts4jjnnX%9%9:   ;  rBcBt\}}|j||yrV)r rr s rCrzSpan.update_active_threads!8!: ;  ;/rB)NNNTNNNNNNNNmanualNNN)%r:r;r<rrrrrrrrpropertyr5rSENTRYr classmethodrrrrrrrrrrrrrrrrr$r(r*rrArBrCrrs:I:#  # @0H8   , ,(4':':(TTT2  --^/(  0   '  BA= E#$L%NB 0rBrceZdZdZdZdddej ffd ZdZdZ fdZ fd Z e d Z d Z ddd fd ZddZdZfdZfdZfdZdZdZxZS)r4aiThe Transaction is the root element that holds all the spans for Sentry performance instrumentation. :param name: Identifier of the transaction. Will show up in the Sentry UI. :param parent_sampled: Whether the parent transaction was sampled. If True this transaction will be kept, if False it will be discarded. :param baggage: The W3C baggage header value. (see https://www.w3.org/TR/baggage/) :param source: A string describing the source of the transaction name. This will be used to determine the transaction's type. See https://develop.sentry.dev/sdk/event-payloads/transaction/#transaction-annotations for more information. Default "custom". :param kwargs: Additional arguments to be passed to the Span constructor. See :py:class:`sentry_sdk.tracing.Span` for available arguments. ) r9rGrH sample_rater _contexts_profile_continuous_profile_baggagerr.Nc :t|di|||_||_d|_||_i|_i|_d|_d|_ ||_ |jdn|jj}|||_ yt|j|_ yNrA)superrr9rGr4rHrr5r6r7r8r_generate_sample_randr+)rYr9rHrJrGrbaggage_sample_randrs rCrzTransaction.__init__,s "6"  , #'  MM)Dt}}/I/I/K   * 3D  5dmm DD rBcd|jjd|jd|jd|jd|j d|j d|jd|jd |jd S) Nrz(name=z, op=rrrrz , source=rr) rr:r9r0r+r,r-r/rGr8rXs rCrzTransaction.__repr__JsU ''   ##     rBc>|jduxs|jduS)zReturns whether the transaction might have been started. If this returns False, we know that the transaction was not started with sentry_sdk.start_transaction, and therefore the transaction will be discarded. NF)rr/rXs rC_possibly_startedzTransaction._possibly_started[s#""$.G$,,%2GGrBc|jstjdt||j |j j |S)NzTransaction was entered without being started with sentry_sdk.start_transaction.The transaction will not be sent to Sentry. To fix, start the transaction bypassing it to sentry_sdk.start_transaction.)r@rdebugr;rr6)rYrs rCrzTransaction.__enter__gsL%%' LL>   == $ MM # # % rBc|j|jj||||j|jjt||||yrV)r6rr7stopr;)rYrrWrrs rCrzTransaction.__exit__wsR == $ MM " "2ub 1  # # /  $ $ ) ) + UB'rBc|S)znThe root element of the span tree. In the case of a transaction it is the transaction itself. rArXs rCr5z"Transaction.containing_transactions  rBc|}|tjdtd|}t|tj r(tjdtd|j S|S)z Logic to get the scope from the arguments passed to finish. This function exists for backwards compatibility with the old finish. TODO: Remove this function in the next major version. zMThe `hub` parameter is deprecated. Please use the `scope` parameter, instead.rzDPassing a Hub to finish is deprecated. Please pass a Scope, instead.)rrrrrHubr7)rY scope_arghub_arg scope_or_hubs rC_get_scope_from_finish_argsz'Transaction._get_scope_from_finish_argssb!   MM_"  #L lJNN 3 MMV"   %% %rBr2c |jy|j||}|xs"|jxstj}tj }|j sy|j|jdurtjdntjd|jryt|jrd|jr|jjdkDrd}nd}|jj!|d |jj!|d y|j"stj$d d |_t&|Q|||js"|jtj$d y|jj*Dcgc]}|j|j- }}t/|jj*t/|z }||jj0z} d|_i} | j3|j4| j3d|j7i|j9} | | j3d| id|j"d|j:i| |j<|j|j>|d} | dkDr| | d<|j@0|j@jCr|j@| d<d|_ |jD| d<|jF!|jFj-} | r| | d<|jI| Scc}w)auFinishes the transaction and sends it to Sentry. All finished spans in the transaction will also be sent to Sentry. :param scope: The Scope to use for this transaction. If not provided, the current Scope will be used. :param end_timestamp: Optional timestamp that should be used as timestamp instead of the current time. :param hub: The hub to use for this transaction. This argument is DEPRECATED. Please use the `scope` parameter, instead. :return: The event ID if the transaction was sent to Sentry, otherwise None. NFz.Discarding transaction because sampled = FalsezSDiscarding transaction because it was not started with sentry_sdk.start_transactionr backpressurer4r) data_categoryrzCTransaction has no name, falling back to ``.zz1Discarding transaction without sampling decision.traceprofilerG)typertransaction_infocontextsr"rr6r}_dropped_spansr!r )%rrLr7rrr is_activerr/rrB transporthas_tracing_enabledrmonitordownsample_factorrecord_lost_eventr9rr;rr}r$rr~rr5r(r*rGrr6r6validrr capture_event)rYr7rr2clientreasonrfinished_spanslen_diffr~rUprofile_contexteventr%rs rCrzTransaction.finishs, >> %00 3 EEz'C'C'E&&(!    &||u$ MN i$7$G>>fnn&F&F&J+F*F  2262W  2262Pyy NNU 2DI um,||||#RS++11 ~~) LLN  t**001C4GG 4#6#6#D#DD #'$"8"8":;<224  & OOY8 9"99!)4;; 7 JJ#33#   1 &3E" # == $)<)<)>#}}E)  DM $ 2 2n  ! ! -"44<<>O,;()""5))c s5#Mc`tjdtd||d|j|<yrrrs rCrzTransaction.set_measurement0rrBc"||j|<y)aSets a context. Transactions can have multiple contexts and they should follow the format described in the "Contexts Interface" documentation. :param key: The name of the context. :param value: The information about the context. N)r5rs rC set_contextzTransaction.set_context>s$srBcLt|||jdd|iy)zySets the status of the Transaction according to the given HTTP status. :param http_status: The HTTP status code.response status_codeN)r;rrg)rYrrs rCrzTransaction.set_http_statusIs'  , m[%ABrBc~t|}|j|d<|j|d<|j|d<|S)zrz> r.)r0r9FNtraces_samplerrHtraces_sample_rateTracing)rGzN[Tracing] Discarding {transaction_description} because of invalid sample rate.)transaction_descriptionrz?[Tracing] Discarding {transaction_description} because {reason}z"traces_sampler returned 0 or Falseztraces_sample_rate is set to 0)rur`z,[Tracing] Starting {transaction_description}z}[Tracing] Discarding {transaction_description} because it's not included in the random sample (sampling rate = {sample_rate}))rur4)rrformatr0r9rYrr/r@r4callablerr rrrZr[rBrr from_float)rYsampling_contextr_rur4s rC_set_initial_sampling_decisionz*Transaction._set_initial_sampling_decisionqs,*&&("<"C"C(,dgg $Rtyy#D#  #6>>2 DL  << #$T\\2D  **+;<= -FNN+ ,-= > $$45A!!12^^$89 $K B NN`gg,Ch  !DL  - >>   6>>#C#C C C  LLQXX,C$FNN$6$67G$HI== Y !DL ((7+=+=d>N>N+OO << LL>EE,CF  LLPWW,C $ 0 0W rBr/r-)r:r;r<rrrNr\rrr@rrr0r5rLrrrgrr$r(rrz __classcell__)rs@rCr4r4 s" I  '' E< " H (  F@*  @*D B $C  drBr4ceZdZdZedZejfdZdZ dZ dZ dZ dZ d Zd Zd Zd Zd ZdZdZ ddddZddZdZdZdZy)rc4d|jjzS)Nz<%s>)rr:rXs rCrzNoOpSpan.__repr__s////rBcyrVrArXs rCr5zNoOpSpan.containing_transactionsrBc tSrV)r)rYrrs rCrzNoOpSpan.start_childs zrBcy)Nr.rArXs rCrzNoOpSpan.to_traceparentsrBcyrVrArXs rCrzNoOpSpan.to_baggagerBcyrVrArXs rCrzNoOpSpan.get_baggagerrBctdSr:)iterrXs rCrzNoOpSpan.iter_headerss BxrBcyrVrArs rCrzNoOpSpan.set_tag rBcyrVrArs rCrzNoOpSpan.set_datarrBcyrVrArs rCrzNoOpSpan.set_statusrrBcyrVrArs rCrzNoOpSpan.set_http_statusrrBcy)NTrArXs rCrzNoOpSpan.is_successrrBciSrVrArXs rCr$zNoOpSpan.to_json  rBciSrVrArXs rCr(zNoOpSpan.get_trace_contextrrBciSrVrArXs rCr*zNoOpSpan.get_profile_contextrrBNrMcy)z_ The `hub` parameter is deprecated. Please use the `scope` parameter, instead. NrA)rYr7rr2s rCrzNoOpSpan.finishs rBcyrVrArs rCrzNoOpSpan.set_measurement#rrBcyrVrArs rCrgzNoOpSpan.set_context'rrBcyrVrArs rCrzNoOpSpan.init_span_recorder+rrBcyrVrA)rYrys rCrzz'NoOpSpan._set_initial_sampling_decision/rrBr/r-)r:r;r<rr0r5rr1rrrrrrrrrrr$r(r*rrrgrrzrArBrCrrs0(4':':             rBrcyrVrAfuncs rCrQrQ6 rBcyrVrArs rCrQrQ;rrBc&ddlm}|r||S|S)av Decorator to start a child span under the existing current transaction. If there is no current transaction, then nothing will be traced. .. code-block:: :caption: Usage import sentry_sdk @sentry_sdk.trace def my_function(): ... @sentry_sdk.trace async def my_async_function(): ... r)start_child_span_decorator)sentry_sdk.tracing_utilsr)rrs rCrQrQAs&D )$//))rB)rIrrr<rYrignore)rrV)Qdecimalrrrrrrenumrrsentry_sdk.constsrr r 'sentry_sdk.profiler.continuous_profilerr sentry_sdk.utilsr r rrrtypingrcollections.abcrrrrrrrrrrrrrtyping_extensionsrr r!r"r#(sentry_sdk.profiler.transaction_profilerr$sentry_sdk._typesr%r&r'r(r*rFr=rKrrrNr_LOW_QUALITY_TRANSACTION_SOURCESr[r]SOURCE_FOR_STYLErxrzrr4rrQrrIrrr<rYrcatch_warnings simplefilterrsentry_sdk.metricsrrArBrCrs 22@@C!AA 3#A AI@9aYe9av QJe Q 3 N ) T # "++&00%//066  ! !#--&,,%++  " " $$N$$2d0d0NI$IXY tY x     *>X3H($672333s G//G8