o S۷i$@s$ddlZddlZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z ddl mZmZddlZddlZddlmZmZmZmZddlmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#ddl$m%Z%e%rdd l$m&Z&dd l$m'Z'dd l$m(Z(dd l$m)Z)dd l$m*Z*ddl$m+Z+ddl$m,Z,ddl-m.Z.e/dZ0dZ1GdddeZ2ddde3fddZ4ddde3fddZ5ej6  ddd d!d d"d d#d$d%e3d&e3d'e7dd(fd)d*Z8 + , - .  dd/d0Z9dd3d4Z:d5e3d6d$d7d8d9d8d:d$d;d$de3fdd?Z D $  EddFdGZ?dd dHe7dd$fdIdJZ@GdKdLdLZAGdMdNdNZBdOdPdQe7de3fdRdSZCddVdWZDdddejEf Y Z $ [  \ ]  dd^d_ZFdddbdcZGdddddeZHdfdgdhd$didjdeIfdkdlZJ m n o p  jddqdrZKdsd dte7ddufdvdwZL dd\dxdZe7dydde7fdzd{ZMd\dxde7fd|d}ZNd\dxd~e3dddydddf ddZOdddZPd\dxd~e3dd ddfddZQd-dd\dxd~e3dZe7dd dddydddfddZRd-dd\dxd~e3dd ddf ddZSddde3fddZTddde7ddfddZUddlVmWZWmXZXmYZYe%rddlVmZZZdSdS)N)MappingMutableMapping) timedelta)Random)quoteunquote)OPSPANDATA SPANSTATUS SPANTEMPLATE) capture_internal_exceptionsfilename_for_moduleloggermatch_regex_listqualname_from_function safe_repr to_string try_convert is_sentry_url_is_external_source_is_in_project_root_module_in_list) TYPE_CHECKING)Any)Dict) Generator)Optional)Union)Iterator)Tuple) FrameTypez5^[ ]*([0-9a-f]{32})?-?([0-9a-f]{16})?-?([01])?[ ]*$z(([a-zA-Z0-9+/]{4})*([a-zA-Z0-9+/]{2,3})?c@sPeZdZ ddddeddfddZd edd fd d Zdefd dZdddZdS)EnvironHeadersHTTP_environzMapping[str, str]prefixreturnNcCs||_||_dSN)r#r$)selfr#r$r(N/home/ubuntu/vllm_env/lib/python3.10/site-packages/sentry_sdk/tracing_utils.py__init__Bs zEnvironHeaders.__init__key Optional[Any]cCs|j|j|ddSN-_)r#r$replaceupper)r'r+r(r(r) __getitem__JzEnvironHeaders.__getitem__cCstddt|DS)Ncss|]}dVqdS)Nr().0r/r(r(r) Nsz)EnvironHeaders.__len__..)sumiterr'r(r(r)__len__MszEnvironHeaders.__len__Generator[str, None, None]ccsP|jD]!}t|ts q|dd}||jsq|t|jdVqdSr-)r# isinstancestrr0r1 startswithr$len)r'kr(r(r)__iter__Ps   zEnvironHeaders.__iter__)r")r%r;) __name__ __module__ __qualname__r=r*r2intr:rAr(r(r(r)r!As r!optionsOptional[Dict[str, Any]]r%cCs:|durdSt|dduo|ddup|dduS)z} Returns True if either traces_sample_rate or traces_sampler is defined and enable_tracing is set and not false. NFenable_tracingtraces_sample_ratetraces_sampler)boolgetrFr(r(r)has_tracing_enabled\s rNOptional[dict[str, Any]]cCs$|durdS|dp iddkS)NF _experimentstrace_lifecyclestream)rLrMr(r(r)has_span_streaming_enabledmsrSFmanualcursorrquery params_list paramstyle Optional[str] executemanyrecord_cursor_repr span_originz.Generator[sentry_sdk.tracing.Span, None, None]c cs tjdddr|r|dgkrd}|dkrd}nd}d}t||}i}|dur/||d<|dur7||d<|r=d|d <|rG|durG||d <ttj|d |d Wdn1s]wYtjtj ||d }| D] \} } | | | qp|VWddS1swYdS)NrPrecord_sql_paramsFpyformatformatz db.paramsz db.paramstyleTzdb.executemanyz db.cursorrV)messagecategorydata)opnameorigin) sentry_sdk get_clientrFrL _format_sqlr add_breadcrumb start_spanrDBitemsset_data) rUrVrWrXrZr[r\rbspanr@vr(r(r)record_sql_queriests@   "rpscopesentry_sdk.Scopernsentry_sdk.tracing.SpancCs|jtjkr|j|jdd|jddS|jtjkrZd}|jt j }|rAd|kr.dkr3nnd}nd|kr=dkrAnnd}|rO|jd d |j|d dS|jd d |jd dS|jd krl|jd d |j|jddSdS)Nredis)r`typerarbiiWerroriiwarninghttphttplib)rurarblevel)rurarb subprocess)rurar`rb) rcrDB_REDISri description_tags HTTP_CLIENT_datarLr HTTP_STATUS_CODE)rqrnrz status_coder(r(r)"maybe_create_breadcrumbs_from_spans2       rframer cCs z|jjWStyYdSwr&)f_code co_filename Exception)rr(r(r)_get_frame_module_abs_paths   ris_sentry_sdk_frame namespacein_app_includeOptional[list[str]]in_app_excludeabs_path project_rootcCs6t||}t|p t||}| o|pt||o| Sr&)rrr)rrrrrrshould_be_includedshould_be_excludedr(r(r)_should_be_includeds rc Cst}|dur=t|}z|jd}Wn tyd}Ynw|duo(|d}t||||||d}|r6n |j}|dusd}|durz|j } Wn tySd} Ynw| dur`| t j |j z|jd}Wn tysd}Ynw|dur| t j |t|} | dur|durt|| } n|dur| |r| |dtj} n| } | t j| z|jj} Wn tyd} Ynw| dur| t j|jjdSdSdS)zB Adds OTel compatible source code information to the span NrBz sentry_sdk.)rrrrrr)sys _getframer f_globalsrLrr>rf_backf_linenormr CODE_LINENOCODE_NAMESPACEr r0lstripossep CODE_FILEPATHrco_name CODE_FUNCTION) rnrrrrrrrrlinenofilepath in_app_path code_functionr(r(r) add_sourcesp         rcCt}|s dS|jdus|jdurdS|jdd}|s!dS|j|j}|jdd}|tdd|k}|s;dSt||jd|jd |jd d dS) zO Adds OTel compatible source code information to a database query span Nenable_db_query_sourceTdb_query_source_threshold_msrr4 millisecondsrrrrnrrr rfrg is_active timestampstart_timestamprFrLrr)rnclientshould_add_query_sourceduration threshold slow_queryr(r(r)add_query_source&&    rcCr) z] Adds OTel compatible source code information to a span for an outgoing HTTP request Nenable_http_request_sourceT http_request_source_threshold_msrr4rrrrrr)rnrshould_add_request_sourcerrrr(r(r)add_http_request_sourceDrrheader+Optional[Dict[str, Union[str, bool, None]]]cCs|sdS|dr|dr|dd}t|}|sdS|\}}}d}|r0dt|d}|r:dt|d}|r@|d k}|||d S) zL Given a `sentry-trace` header string, return a dictionary of data. Nz00-z-00z{:032x}z{:016x}0)trace_idparent_span_idparent_sampled)r>endswithSENTRY_TRACE_REGEXmatchgroupsr_rE)rrrr sampled_strrr(r(r)extract_sentrytrace_databs&  rsqlcCsXd}zt|dr||}t|tr||jj}Wn ty%d}Ynw|p+t|S)Nmogrify) hasattrrr<bytesdecode connectionencodingrr)rUrreal_sqlr(r(r)rhs     rhc@s eZdZdZdZ      d0        d1ddZe    d2ddZede fddZ e j de ddfddZ ede fddZ e j de ddfddZ ed3ddZ de fdd Zd4d"d#Zd5d%d&Zd6d(d)Zde fd*d+Zd7d,d-Zd8d.d/ZdS)9PropagationContextzJ The PropagationContext represents the data of a trace in Sentry. ) _trace_id_span_idrrbaggageNrrYspan_idrrOptional[bool]dynamic_sampling_contextOptional[Dict[str, str]]rOptional[Baggage]r%cCsP||_ ||_ ||_ ||_ ||_ |dur$|dur&t||_dSdSdSr&)rrrrrBaggage)r'rrrrrrr(r(r)r*s zPropagationContext.__init__ incoming_dataDict[str, Any]cCstt}t|}|t}t|}|dur|S|t}|r"t|nd}t|s*|S| ||r4||_ | |Sr&) rnormalize_incoming_datarLSENTRY_TRACE_HEADER_NAMErBAGGAGE_HEADER_NAMErfrom_incoming_header_should_continue_traceupdater_fill_sample_rand)clsrpropagation_contextnormalized_datasentry_trace_headersentrytrace_databaggage_headerrr(r(r)from_incoming_datas    z%PropagationContext.from_incoming_datacCs|js tj|_|jS)z!The trace id of the Sentry trace.)ruuiduuid4hexr9r(r(r)rs zPropagationContext.trace_idvaluecC ||_dSr&)rr'rr(r(r)r cCs |js tjdd|_|jS)z+The span id of the currently executed span.rN)rrrrr9r(r(r)rszPropagationContext.span_idcCrr&)rrr(r(r)rrrGcCs |Sr&) get_baggagerr9r(r(r)rs z+PropagationContext.dynamic_sampling_contextcCs|jd|jS)Nr.)rrr9r(r(r)to_traceparentsz!PropagationContext.to_traceparentrcCs|jdur t||_|jSr&)rr!populate_from_propagation_contextr9r(r(r)rs  zPropagationContext.get_baggageIterator[Tuple[str, str]]ccs2t|fV|}|rt|fVdSdS)zw Creates a generator which returns the propagation_context's ``sentry-trace`` and ``baggage`` headers. N)rrr serializer)r'rr(r(r) iter_headerss  zPropagationContext.iter_headers other_dictc Cs8|D]\}}zt|||WqtyYqwdS)zU Updates the PropagationContext with data from the given dictionary. N)rlsetattrAttributeError)r'rr+rr(r(r)rs zPropagationContext.updatecCsd|j|j|j|j|jS)Nz\)r_rrrrrr9r(r(r)__repr__szPropagationContext.__repr__c Cs|jdurdStt|jjd}|dur!d|kr dkr!dStt|jjd}t|j|\}}z t|j||fd}Wnt yUt d|jd|d YdSw|d |jjd<dS) a Ensure that there is a valid sample_rand value in the baggage. If there is a valid sample_rand value in the baggage, we keep it. Otherwise, we generate a sample_rand value according to the following: - If we have a parent_sampled value and a sample_rate in the DSC, we compute a sample_rand value randomly in the range: - [0, sample_rate) if parent_sampled is True, - or, in the range [sample_rate, 1) if parent_sampled is False. - If either parent_sampled or sample_rate is missing, we generate a random value in the range [0, 1). The sample_rand is deterministically generated from the trace_id, if present. This function does nothing if there is no baggage. N sample_randrr4 sample_rateintervalz5Could not backfill sample_rand, since parent_sampled=z and sample_rate=..6f) rrfloat sentry_itemsrL_sample_rand_ranger_generate_sample_randr ValueErrorrdebug)r'rrlowerr1r(r(r)r!s&    z$PropagationContext._fill_sample_randcCs|jdurdS|jjdS)zAConvenience method to get the sample_rand value from the baggage.Nr)rrrLr9r(r(r) _sample_randPs zPropagationContext._sample_rand)NNNNNN)rrYrrYrrYrrrrrrr%N)rrr%r)r%rG)r%r)r%r)rrr%Nr%N)r%rY)rBrCrD__doc__ __slots__r* classmethodrpropertyr=rsetterrrrrrrrrr r(r(r(r)rs^        /rc@seZdZdZdZdZedZ  d1ddd e d e fd d Z e d d     d2ddZ e d3ddZe    d4ddZe    d5d d!Zd6d"d#Zd7d$d%Zd8d'e de fd(d)Zede de fd*d+Zd9d-d.Zde fd/d0Zd S):raF The W3C Baggage header information (see https://www.w3.org/TR/baggage/). Before mutating a `Baggage` object, calling code must check that `mutable` is `True`. Mutating a `Baggage` object that has `mutable` set to `False` is not allowed, but it is the caller's responsibility to enforce this restriction. rthird_party_itemsmutablezsentry-z^sentry-rTrDict[str, str]rrcCs||_||_||_dSr&r)r'rrrr(r(r)r*fs zBaggage.__init__N)r rrYr r%c Csi}d}d}|rU|dD]G}d|vrq t5|}|d\}}tj|r;t|dd} t||| <d}n ||r@dnd|7}Wdn1sOwYq |durat||d <d}t|||S) zF freeze if incoming header already has sentry baggage rT,=r.r4FNr)splitr striprSENTRY_PREFIX_REGEXrrr=) rrr rrritemr+val baggage_keyr(r(r)rps,     zBaggage.from_incoming_headerrqsentry_sdk.scope.ScopercCs|jdur tiSt|jS)zC Deprecated: use populate_from_propagation_context N)_propagation_contextrr)rrqr(r(r) from_optionss  zBaggage.from_optionsrrcCsi}d}d}t}|st|S|j}|j|d<|dr%|d|d<|dr0|d|d<|jrC|jj|d<|jj rC|jj |d<|drPt |d|d <t|||S) NrFr environmentrelease public_keyorg_idrIr) rfrgrrrFrrL parsed_dsnr"r#r=)rrrrrrrFr(r(r)rs&         z)Baggage.populate_from_propagation_context transactionsentry_sdk.tracing.TransactioncCst}i}|st|S|jpi}|j|d<|jd|d<|dr*|d|d<|dr5|d|d<|jrH|jj |d<|jj rH|jj |d<|j rU|j t vrU|j |d<|jd urat|j|d <|jd uro|jrkd nd |d <|jr}|jjr}||jjt|ddS)z Populate fresh baggage entry with sentry_items and make it immutable if this is the head SDK which originates traces. rrrr r!r"r#r%NrtruefalsesampledFr)rfrgrrrFrr rLr$r"r#rdsourceLOW_QUALITY_TRANSACTION_SOURCESrr=r)_baggagerr)rr%rrrFr(r(r)populate_from_transactions4             z!Baggage.populate_from_transactioncCs d|_dS)NFr*r9r(r(r)freezes zBaggage.freezecCs$i}|jD]\}}|||<q|Sr&)rrl)r'rr+rr(r(r)rs z Baggage.dynamic_sampling_contextFinclude_third_partyc Csg}|jD]+\}}ttjt|dtt|}||Wdn1s-wYq|r;||jd |S)Nrr) rrlr r SENTRY_PREFIXrr=appendrjoin)r'r0rlr+rrr(r(r)rs   zBaggage.serializecCsddd|dDS)zRemove Sentry baggage from the given header. Given a Baggage header, return a new Baggage header with all Sentry baggage items removed. rcss$|] }tj|s|VqdSr&)rrrr)r5rr(r(r)r6s z/Baggage.strip_sentry_baggage..)r3r)rr(r(r)strip_sentry_baggages zBaggage.strip_sentry_baggageOptional[float]cCs:tt|jd}|durd|krdkr|SdSdS)zConvenience method to get the sample_rand value from the sentry_items. We validate the value and parse it as a float before returning it. The value is considered valid if it is a float in the range [0, 1). rN?)rrrrL)r'rr(r(r)r s zBaggage._sample_randcCsd|jddd|jdS)Nz )rrr9r(r(r)r#r3zBaggage.__repr__)rT)rrYr rYr%r)rqrr%r)rrr%r)r%r&r%rr )r%r)F)r%r5)rBrCrDr r r1recompilerr=rKr*rrrrr.r/rr staticmethodr4r rr(r(r(r)rXsX    "     1    rrzsentry_sdk.client.BaseClienturlcCs&|jd}t||r dSt||ddS)zy Returns True if url matches trace_propagation_targets configured in the given client. Otherwise, returns False. trace_propagation_targetsFT)substring_matching)rFrr)rr<r=r(r(r)should_propagate_trace's  r?rrcCsHi}|D]\}}|dr|dd}|dd}|||<q|S)z Normalizes incoming data so the keys are all lowercase with dashes instead of underscores and stripped from known prefixes. r"Nr/r.)rlr>r0r )rrbr+rr(r(r)r3s   rrcOptional[Union[str, OP]]rd attributestemplater cs&ddlmd fdd }|S) a Create a span decorator that can wrap both sync and async functions. :param op: The operation type for the span. :type op: str or :py:class:`sentry_sdk.consts.OP` or None :param name: The name of the span. :type name: str or None :param attributes: Additional attributes to set on the span. :type attributes: dict or None :param template: The type of span to create. This determines what kind of span instrumentation and data collection will be applied. Use predefined constants from :py:class:`sentry_sdk.consts.SPANTEMPLATE`. The default is `SPANTEMPLATE.DEFAULT` which is the right choice for most use cases. :type template: :py:class:`sentry_sdk.consts.SPANTEMPLATE` r)should_send_default_piifrr%cstd fdd }zt|_Wn ty"Ynwtd fdd }zt|_Wn tyEYnwtrM|S|S) zD Decorator to create a span for the given function. argsrkwargsr%c st}|durtdt|i|IdHSpt}p'tp'd}t||}}|j||d,}|p>it||||||i|IdH}t ||||WdS1sgwYdSNzbCannot create a child span for %s. Please start a Sentry transaction before calling this function.r)rcrd get_current_spanrrr _get_span_op_get_span_name start_child update_data_set_input_attributes_set_output_attributes rFrG current_spanspan_op function_name span_namesend_piirnresultrBrErdrcrDrCr(r) async_wrapper_s2  $zDcreate_span_decorator..span_decorator..async_wrapperc st}|durtdt|i|Spt}p#tp#d}t||}}|j||d)}|p:it||||||i|}t ||||WdS1s`wYdSrHrIrQrXr(r) sync_wrappers0  $zCcreate_span_decorator..span_decorator..sync_wrapperN)rFrrGrr%r) functoolswrapsinspect signature __signature__riscoroutinefunction)rErYrZrBrdrcrDrC)rEr)span_decoratorZs"   z-create_span_decorator..span_decoratorN)rErr%r)sentry_sdk.scoperD)rcrdrBrCrbr(rar)create_span_decoratorBs TrdOptional[sentry_sdk.Scope]Optional[Span]cCs|pt}|j}|S)zU Returns the currently active span if there is one running, otherwise `None` )rfget_current_scopern)rqrRr(r(r)rJs rJcCsB|pt}|dur|tj|jdur|jtjdSdSdS)z Set the status of the current or given span to INTERNAL_ERROR. Also sets the status of the transaction (root span) to INTERNAL_ERROR. N)rJ set_statusr INTERNAL_ERRORcontaining_transaction)rnr(r(r)set_span_erroreds   rkr6r7rrrtuple[float, float]cCsl|\}}||ks tdt|}t|d}t|d}z |||}W|dSty5|}Y|dSw)aGenerate a sample_rand value from a trace ID. The generated value will be pseudorandomly chosen from the provided interval. Specifically, given (lower, upper) = interval, the generated value will be in the range [lower, upper). The value has 6-digit precision, so when printing with .6f, the value will never be rounded up. The pseudorandom number generator is seeded with the trace ID. z/Invalid interval: lower must be less than upperi@B)rrrE randrange)rrr r1rng lower_scaled upper_scaledsample_rand_scaledr(r(r)rs   rrrrr5cCs,|dus|dur dS|durd|fS|dfS)z Compute the lower (inclusive) and upper (exclusive) bounds of the range of values that a generated sample_rand value must fall into, given the parent_sampled and sample_rate values. NrlTr6r7r()rrr(r(r)rs rr+r+r,cCsTd}t|tr||}|St||r(zt||}W|Sty'd}Y|Sw|S)z Gets a value from a source object. The source can be a dict or an object. It is checked for dictionary keys and object attributes. N)r<dictrLrgetattrr)r+r+rr(r(r) _get_values     ruzUnion[str, SPANTEMPLATE]rGcCs|}|tjkr/d}|r"dD]}||r!t||tr!||}nq |r+d|}|Sd}|S|tjkr;d|}|S|tjkrEd|}|S)zF Get the name of the span based on the template and the name. N)model model_namezchat chatz invoke_agent z execute_tool )r AI_CHATrLr<r=AI_AGENTAI_TOOL)rCrdrGrUrvr+r(r(r)rLs&   rLcCs2tjtjtjtjtjtji}||tj }t |S)z> Get the operation of the span based on the template. ) r ryr GEN_AI_CHATrzGEN_AI_INVOKE_AGENTr{GEN_AI_EXECUTE_TOOLrLFUNCTIONr=)rCmappingrcr(r(r)rK#s rKrVrFztuple[Any, ...]dict[str, Any]c sJi|tjtjtjfvrtjtftjtftjtftjtftjt ftj t ftj t ftj t ftjt ftjt fd dtddddffdd }t|D]7\}}|d krft|trftjgd |d qK|d kr}t|tr}tjgd |d qK|||qK|tjkr|rt||dtj<tjvrttjtj<S)z; Get input attributes for the given span template. ) rvrwagent agent_name max_tokensfrequency_penaltypresence_penalty temperaturetop_ptop_kr+rrr%Ncs>|vr|\}}|durt||r||<dSdSdSdSr&)r<)r+r attribute data_typerBrr(r) _set_from_keyJs   z,_get_input_attributes.._set_from_keypromptuser)rolecontent system_promptsystem)rFrG)r rzr{ryr GEN_AI_REQUEST_MODELr=GEN_AI_AGENT_NAMEGEN_AI_REQUEST_MAX_TOKENSrE GEN_AI_REQUEST_FREQUENCY_PENALTYrGEN_AI_REQUEST_PRESENCE_PENALTYGEN_AI_REQUEST_TEMPERATUREGEN_AI_REQUEST_TOP_PGEN_AI_REQUEST_TOP_Klistrlr< setdefaultGEN_AI_REQUEST_MESSAGESr2rGEN_AI_TOOL_INPUT)rCrVrFrGrr+rr(rr)_get_input_attributes1sF     rusagecsHidtddddffdd }|tjd|tjd |tjd S) z Get usage attributes. rkeysztuple[str, ...]r%Ncs2|D]}t|}|durt|tr||<qdSr&)rur<rE)rrr+rrBrr(r)_set_from_keysss  z-_get_usage_attributes.._set_from_keys) prompt_tokens input_tokens)completion_tokens output_tokens) total_tokens)r=r GEN_AI_USAGE_INPUT_TOKENSGEN_AI_USAGE_OUTPUT_TOKENSGEN_AI_USAGE_TOTAL_TOKENS)rrr(rr)_get_usage_attributesmsrrWc Csi}|tjtjtjfvrqtZ|g}t|d}||t|d}t|d}|||D] }|dur;|t|q.t|d}|durOt |t rO||t j <t|d}|durbt |t rb||t j <Wdn1slwY|tjkr|rt ||t j<|S)z< Get output attributes for the given span template. rmetadataNrvrw)r rzr{ryr rur2rrr<r=r GEN_AI_RESPONSE_MODELrGEN_AI_TOOL_OUTPUT) rCrVrWrBusage_candidatesrmetausage_candidaterwr(r(r)_get_output_attributess0         rSpanrEc Csi}|tjkrtjdtj|i}n$|tjkrtjdi}n|tjkr4tjdtj|i}|j}|dur4||tj <| t ||||| |pCidS)a Set span input attributes based on the given span template. :param span: The span to set attributes on. :param template: The template to use to set attributes on the span. :param send_pii: Whether to send PII data. :param f: The wrapped function. :param args: The arguments to the wrapped function. :param kwargs: The keyword arguments to the wrapped function. invoke_agentrx execute_toolN) r rzr GEN_AI_OPERATION_NAMErryr{GEN_AI_TOOL_NAMEr GEN_AI_TOOL_DESCRIPTIONrrrN) rnrCrVrdrErFrGrB docstringr(r(r)rOs"    rOcCs|t|||p idS)a% Set span output attributes based on the given span template. :param span: The span to set attributes on. :param template: The template to use to set attributes on the span. :param send_pii: Whether to send PII data. :param result: The result of the wrapped function. N)rNr)rnrCrVrWr(r(r)rPs rPrrcCst}|j}|r |jnd}|r|jdnd}|dur2|dur2||kr2td|d|ddS|jdd}|rY|durC|dusK|durY|durYtd|d|ddSd S) z Check if we should continue the incoming trace according to the strict_trace_continuation spec. https://develop.sentry.dev/sdk/telemetry/traces/#stricttracecontinuation Nr#zKStarting a new trace because org IDs don't match (incoming baggage org_id: z, SDK org_id: )Fstrict_trace_continuationzvStarting a new trace because strict trace continuation is enabled and one org ID is missing (incoming baggage org_id: T) rfrgr$r#rrLrrrF)rrr$ client_org_idbaggage_org_idrr(r(r)rs,rheaderszMutableMapping[str, str]sentry_baggagecCs>|td}t|}t|dkrdnd}||||t<dS)zAdd the Sentry baggage to the headers. This function directly mutates the provided headers. The provided sentry_baggage is appended to the existing baggage. If the baggage already contains Sentry items, they are stripped out first. rrrN)rLrrr4r?)rrexisting_baggagestripped_existing_baggage separatorr(r(r)add_sentry_baggage_to_headerss   r)rr,r)r)FrT)rqrrrnrsr%N)rr r%rY) rnrsrrYrrrrr%N)rnrsr%N)rrYr%r)rrr%r) rcrArdrYrBrOrCr r%rr&)rqrer%rf)rnrfr%N)rrrr5r%rm)rrr%r)[ contextlibr[r]rr9rcollections.abcrrdatetimerrandomr urllib.parserrrrfsentry_sdk.constsrr r r sentry_sdk.utilsr r rrrrrrrrrrtypingrrrrrrrrtypesr r:rbase64_strippedr!rKrNrScontextmanagerr=rprrrrrrrrhrrr?rDEFAULTrdrJrkrrrrurLrKrrrrOrPrrsentry_sdk.tracingrr,rrr(r(r(r)s  8            - !  I  !DP  o     < ( , $