uYf tddlZddlZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z dd lm Z ddl Z dd l m Z ejd k\rdd lmZndd lmZdd l mZddlmZddlmZddl mZddl mZddl mZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddl$m%Z%ddl&m'Z'ddl&m(Z(dd l&m)Z*dd!l&m+Z+dd"l&m,Z-dd#l&m.Z.dd$l&m/Z/dd%l&m0Z0dd&l&m1Z1dd'l&m2Z2dd(l3m4Z4dd)l5m6Z6dd*l5m7Z7dd+l5m8Z8dd,l9m:Z:d-d.l;md/Z?d0Z@d1ZAd2ZBd3ZCd4ZDd5ZEd6ZFd7ZGd8ZHd9ZId:ZJd;ZKd<ZLeLe@ZMeLeAZNeLeBZOeLeCZPeQeIeZ^d?ee_e_fd@efdAZ`dBZaeaZbdCZcGdDdEZdGdFdGZeGdHdIZfGdJdKZgGdLdMZhe0ede.eee/efe(ege'ehiZiGdNdOejZky)QN)Any)Dict) FrozenSet)List)Optional)Text)Tuple)cast)Span))Literal)config)SpanLink)Context)!_get_64_highest_order_bits_as_hex) _get_64_lowest_order_bits_as_int) _MetaDictType) AUTO_KEEP) AUTO_REJECT) USER_KEEP)TagsetDecodeError)TagsetEncodeError)TagsetMaxSizeDecodeError)TagsetMaxSizeEncodeError)decode_tagset_string)encode_tagset_values ensure_text)_PROPAGATION_STYLE_NONE)#_PROPAGATION_STYLE_W3C_TRACECONTEXT)HIGHER_ORDER_TRACE_ID_BITS)LAST_DD_PARENT_ID_KEY)MAX_UINT_64BITS)PROPAGATION_STYLE_B3_MULTI)PROPAGATION_STYLE_B3_SINGLE)PROPAGATION_STYLE_DATADOG)W3C_TRACEPARENT_KEY)W3C_TRACESTATE_KEY) get_logger)SAMPLING_DECISION_TRACE_TAG_KEY)SamplingMechanism)validate_sampling_decision)w3c_tracestate_add_p)get_wsgi_headerz ot-baggage-zx-datadog-trace-idzx-datadog-parent-idzx-datadog-sampling-priorityzx-datadog-originb3z x-b3-traceidz x-b3-spanidz x-b3-sampledz x-b3-flagszx-datadog-tags traceparent tracestatecJt|t|jgSN) frozensetr1lower)headers X/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/ddtrace/propagation/http.py_possible_headerr;Ms fof5;;=> ??aj ^ # Start of string ([a-f0-9]{2})- # 2 character hex version ([a-f0-9]{32})- # 32 character hex trace id ([a-f0-9]{16})- # 16 character hex span id ([a-f0-9]{2}) # 2 character hex sample flag (-.+)? # optional, start of any additional values $ # end of string c@|D]}||vst||dcS|S)Nbackslashreplace)errorsr)possible_header_namesheadersdefaultr9s r:_extract_header_valuerCss4'K W wv7IJ JK Nr<rAcontextc|U|jD]A\}}|dtttk(s |j|ttd|Cyyr6)itemslen_HTTP_BAGGAGE_PREFIX_set_baggage_item)rArDkeyvalues r:_attach_baggage_to_contextrL|s]!--/ SJC.S-./3GG))#c2F.G.I*JER Sr<ct|dS)z7Helper to convert hex ids into Datadog compatible ints.)int)hex_ids r:_hex_id_to_dd_idrQs vr?r<cX|tkDrdj|Sdj|S)zGHelper to convert Datadog trace/span int ids into lower case hex valuesz{:032x}{:016x})_MAX_UINT_64BITSformat)dd_ids r:_dd_id_to_b3_idrWs1 &&   E ""r<ceZdZdZedgZedZedZedZ ede de de fd Z ed e de fd Zed Zed Zy)_DatadogMultiHeaderaHelper class for injecting/extract Datadog multi header format Headers: - ``x-datadog-trace-id`` the context trace id as a uint64 integer - ``x-datadog-parent-id`` the context current span id as a uint64 integer - ``x-datadog-sampling-priority`` integer representing the sampling decision. ``<= 0`` (Reject) or ``> 1`` (Keep) - ``x-datadog-origin`` optional name of origin Datadog product which initiated the request - ``x-datadog-tags`` optional tracer tags Restrictions: - Trace tag key-value pairs in ``x-datadog-tags`` are extracted from incoming requests. - Only trace tags with keys prefixed with ``_dd.p.`` are propagated. - The trace tag keys must be printable ASCII characters excluding space, comma, and equals. - The trace tag values must be printable ASCII characters excluding comma. Leading and trailing spaces are trimmed. z_dd.p.upstream_servicesc$|jdS)Nz_dd.p.) startswith)rJs r:_is_valid_datadog_trace_tag_keyz3_DatadogMultiHeader._is_valid_datadog_trace_tag_keys~~h''r<c&tt|dS)NrB)rC_POSSIBLE_HTTP_HEADER_TAGSrAs r:_get_tags_valuez#_DatadogMultiHeader._get_tags_values% &   r<c^ t|jDcic]/\}}|tjvrtj |r||1}}}|Scc}}w#t $rddi}t jddY|St$r ddi}t jd|dY|SwxYw)N_dd.propagation_errorextract_max_sizezfailed to decode x-datadog-tagsTexc_infodecoding_errorz#failed to decode x-datadog-tags: %r) rrFrY_X_DATADOG_TAGS_EXTRACT_REJECTr\rlogwarningrdebug) tags_valuekvmetas r: _extract_metaz!_DatadogMultiHeader._extract_metas X3:>DDFQ0OOO+KKAN 1D$ %( J');D KK9DK I  ! X')9D II;ZRVI W  Xs(A4AAA$B,$B,+B,trace_id_hob_hex low_64_bitsreturnc>t|dj|zdS)NrSrN)rOrU)rrrss r:_put_together_trace_idz*_DatadogMultiHeader._put_together_trace_ids"#i&6&6{&CCRHHr< upper_64_bitsc t|dk7st|ds|jsty#t$rYywxYw)NrNFT)rGrOislower ValueError)rws r:_higher_order_is_validz*_DatadogMultiHeader._higher_order_is_validsG =!R'M20F=K`K`Kb    s 03 ??c\|j |jtjd|y|jtkDrLt t |j|t<t|j|jt<nt |j|t<t |j|t<|j}|t |j|t<|jt|j|t <t"j$sd|jd<yd|jvry|jj'Dcic]/\}}t(j+|rt|t|1}}}|r$ t-|t"j.|t0<yycc}}w#t2$r)d|jd<tj5ddYyt6$r)d |jd<tj5ddYywxYw) N"tried to inject invalid context %rdisabledrd)max_sizeinject_max_sizezfailed to encode x-datadog-tagsTrfencoding_error)trace_idspan_idrjrlrTstrrHTTP_HEADER_TRACE_IDr_meta_HIGHER_ORDER_TRACE_ID_BITSHTTP_HEADER_PARENT_IDsampling_priorityHTTP_HEADER_SAMPLING_PRIORITY dd_originr HTTP_HEADER_ORIGINr_x_datadog_tags_enabledrFrYr\r_x_datadog_tags_max_length_HTTP_HEADER_TAGSrrkr) span_contextrArrnrotags_to_encodes r:_injectz_DatadogMultiHeader._injects  (L,@,@,H II:L I   #3 3-00PQ]QfQf0g,hG( )?``l`u`u>vL  : ;,/ 0E0E,FG( )),\-A-A)B%&(::  (589W9W5XG1 2  ! ! -*5l6L6L*MG& '--:DL  6 7  #l&8&8 8  %**002 1"BB1E NKN *    N-A"V-N-N.)*  , N>O ""#:; = M$ N>N ""#:; = M Ns%4G"G /H+:.H+*H+c tt|}|y t|}|dks |tkDrt j d|ytt|d}tt|t}tt|}d}tj|}|rtj|}|r~t|vrv|t}tj|r't j"rHtj%||}n1dj'||d<|t=t j d||si}|j)t*sdt,j.|t*< | t|}n|}|r t1|}t3|xsdt|xsd||t5t6| S#t$rd}YwxYw#t8tf$rt j;d |||||YywxYw) NrzXInvalid trace id: %r. `x-datadog-trace-id` must be greater than zero and less than 2**640r_zmalformed_tid {}rdz>malformed_tid: %s. Failed to decode trace id from http headers-rrrrrpzdreceived invalid x-datadog-* headers, trace-id: %r, parent-id: %r, priority: %r, origin: %r, tags:%r)rCPOSSIBLE_HTTP_HEADER_TRACE_IDSrOrzrTrjrkPOSSIBLE_HTTP_HEADER_PARENT_IDS(POSSIBLE_HTTP_HEADER_SAMPLING_PRIORITIESrPOSSIBLE_HTTP_HEADER_ORIGINrYrbrqrr{r_128_bit_trace_id_enabledrvrUgetr,r-TRACE_SAMPLING_RULEr.rr r TypeErrorrl) rA trace_id_strrparent_span_idroriginrprmrrs r:_extractz_DatadogMultiHeader._extracts --KWU   <(H q=H'77 KKjlx . +   22Z\cmvw& '   (88A &44Z@D /47#$?@ "99:JK332IIJZ\deH0B0I0IJZ0[,-45 \^noDxx78678I8]8]7^4_D0 1  ,$'(9$:!$5!1$7!)TN+3t"3 -.  o H D:&  IIU!  s$ F+A F=+ F:9F:=)G)(G)N)__name__ __module__ __qualname____doc__r7ri staticmethodr\rbrqrrOrvboolr{rrr<r:rYrYs(&/0I/J%K"((  .II3I3IIcd6N6NpUUr<rYc0eZdZdZedZedZy)_B3MultiHeaderaHelper class to inject/extract B3 Multi-Headers https://github.com/openzipkin/b3-propagation/blob/3e54cda11620a773d53c7f64d2ebb10d3a01794c/README.md#multiple-headers Example:: X-B3-TraceId: 80f198ee56343ba864fe8b2a57d3eff7 X-B3-ParentSpanId: 05e3ac9a4f6e3b90 X-B3-SpanId: e457b5a2e4d86bd1 X-B3-Sampled: 1 Headers: - ``X-B3-TraceId`` header is encoded as 32 or 16 lower-hex characters. - ``X-B3-SpanId`` header is encoded as 16 lower-hex characters. - ``X-B3-Sampled`` header value of ``0`` means Deny, ``1`` means Accept, and absent means to defer. - ``X-B3-Flags`` header is used to set ``1`` meaning Debug or an Accept. Restrictions: - ``X-B3-Sampled`` and ``X-B3-Flags`` should never both be set Implementation details: - Sampling priority gets encoded as: - ``sampling_priority <= 0`` -> ``X-B3-Sampled: 0`` - ``sampling_priority == 1`` -> ``X-B3-Sampled: 1`` - ``sampling_priority > 1`` -> ``X-B3-Flags: 1`` - Sampling priority gets decoded as: - ``X-B3-Sampled: 0`` -> ``sampling_priority = 0`` - ``X-B3-Sampled: 1`` -> ``sampling_priority = 1`` - ``X-B3-Flags: 1`` -> ``sampling_priority = 2`` - ``X-B3-TraceId`` is not required, will use ``None`` when not present - ``X-B3-SpanId`` is not required, will use ``None`` when not present cJ|j |jtjd|yt |j|t <t |j|t <|j}|.|dkr d|t<y|dk(r d|t<y|dkDr d|t<yyy)Nr}rrr01) rrrjrlrW_HTTP_HEADER_B3_TRACE_ID_HTTP_HEADER_B3_SPAN_IDr_HTTP_HEADER_B3_SAMPLED_HTTP_HEADER_B3_FLAGS)rrArs r:rz_B3MultiHeader._injects  (L,@,@,H II:L I ,;L$ $ "c>(3%^(1%|$-!!"3  :&  IIg   sAB(C  C Nrrrrrrrrr<r:rrss0#J55$77r<rc0eZdZdZedZedZy)_B3SingleHeaderaGHelper class to inject/extract B3 Single Header https://github.com/openzipkin/b3-propagation/blob/3e54cda11620a773d53c7f64d2ebb10d3a01794c/README.md#single-header Format:: b3={TraceId}-{SpanId}-{SamplingState}-{ParentSpanId} Example:: b3: 80f198ee56343ba864fe8b2a57d3eff7-e457b5a2e4d86bd1-1-05e3ac9a4f6e3b90 Values: - ``TraceId`` header is encoded as 32 or 16 lower-hex characters. - ``SpanId`` header is encoded as 16 lower-hex characters. - ``SamplingState`` header value of ``0`` means Deny, ``1`` means Accept, and ``d`` means Debug - ``ParentSpanId`` header is not used/ignored if sent Restrictions: - ``ParentSpanId`` value is ignored/not used Implementation details: - Sampling priority gets encoded as: - ``sampling_priority <= 0`` -> ``SamplingState: 0`` - ``sampling_priority == 1`` -> ``SamplingState: 1`` - ``sampling_priority > 1`` -> ``SamplingState: d`` - Sampling priority gets decoded as: - ``SamplingState: 0`` -> ``sampling_priority = 0`` - ``SamplingState: 1`` -> ``sampling_priority = 1`` - ``SamplingState: d`` -> ``sampling_priority = 2`` - ``TraceId`` is not required, will use ``None`` when not present - ``SpanId`` is not required, will use ``None`` when not present c@|j |jtjd|ydj t |jt |j}|j }| |dkr|dz }n|dk(r|dz }n |dkDr|dz }||t<y)Nr}z{}-{}rz-0r0z-1z-d)rrrjrlrUrWr_HTTP_HEADER_B3_SINGLE)rrA single_headerrs r:rz_B3SingleHeader._injects  (L,@,@,H II:L I |7L7L'M_k_s_sOtu (::  ( A%% "a'% "Q&% *7&'r<ctt|}|syd}d}d}|jd}d}d}t|dk(r|\}n+t|dk(r|\}}nt|dk\r |dd\}}} |t |xsd}|t |xsd}d}|#|dk(rt }n|dk(rt }n |dk(rt}t|||S#ttf$rtjd |YywxYw) Nrr0rr rrdrz"received invalid b3 header, b3: %r) rC&_POSSIBLE_HTTP_HEADER_B3_SINGLE_HEADERsplitrGrrrrrrrzrjrl) rArrrrpartsrrrs r:rz_B3SingleHeader._extract s2..TV]^ ##C(   u:?JWZ1_(- %L+Z1_16r .L+w '*<8@D&)+6>$ $ "c>(3%^(1%^(1%!"3  :&  II4   s.AC%C-,C-Nrrr<r:rrs0$L88"66r<rc eZdZdZedZedZedZe d dede ede e fd Z ed Z ed d Z ed Zy) _TraceContexta Helper class to inject/extract W3C Trace Context https://www.w3.org/TR/trace-context/ Overview: - ``traceparent`` header describes the position of the incoming request in its trace graph in a portable, fixed-length format. Its design focuses on fast parsing. Every tracing tool MUST properly set traceparent even when it only relies on vendor-specific information in tracestate - ``tracestate`` header extends traceparent with vendor-specific data represented by a set of name/value pairs. Storing information in tracestate is optional. The format for ``traceparent`` is:: HEXDIGLC = DIGIT / "a" / "b" / "c" / "d" / "e" / "f" value = version "-" version-format version = 2HEXDIGLC version-format = trace-id "-" parent-id "-" trace-flags trace-id = 32HEXDIGLC parent-id = 16HEXDIGLC trace-flags = 2HEXDIGLC Example value of HTTP ``traceparent`` header:: value = 00-4bf92f3577b34da6a3ce929d0e0e4736-00f067aa0ba902b7-01 base16(version) = 00 base16(trace-id) = 4bf92f3577b34da6a3ce929d0e0e4736 base16(parent-id) = 00f067aa0ba902b7 base16(trace-flags) = 01 // sampled The format for ``tracestate`` is key value pairs with each entry limited to 256 characters. An example of the ``dd`` list member we would add is:: "dd=s:2;o:rum;t.dm:-4;t.usr.id:baz64" Implementation details: - Datadog Trace and Span IDs are 64-bit unsigned integers. - The W3C Trace Context Trace ID is a 16-byte hexadecimal string. - If the incoming traceparent is invalid we DO NOT use the tracecontext headers. Otherwise, the trace-id value is set to the hex-encoded value of the trace-id. If the trace-id is a 64-bit value (i.e. a Datadog trace-id), then the upper half of the hex-encoded value will be all zeroes. - The tracestate header will have one list member added to it, ``dd``, which contains values that would be in x-datadog-tags as well as those needed for propagation information. The keys to the ``dd`` values have been shortened as follows to save space: ``sampling_priority`` = ``s`` ``origin`` = ``o`` ``_dd.p.`` prefix = ``t.`` c&|jddS)N~=)replace)tag_vals r:decode_tag_valz_TraceContext.decode_tag_valssC((r<ctj|j}|td|z|j \}}}}}|dk(rtd|z|dk7rt j d|n|dk(r|td|zt|}t|}|dk(r td|dk(r td t|} | d zrd nd} ||| fS) zIf there is no traceparent, or if the traceparent value is invalid raise a ValueError. Otherwise we extract the trace-id, span-id, and sampling priority from the traceparent header. zInvalid traceparent version: %sffz(ff is an invalid traceparent version: %s00z=unsupported traceparent version:%r, still attempting to parsezRTraceparents with the version `00` should contain 4 values delimited by a dash: %srz0 value for trace_id is invalidz0 value for span_id is invalidr0)_TRACEPARENT_HEX_REGEXmatchstriprzgroupsrjrkrQ) tpvalid_tp_valuesversion trace_id_hex span_id_hextrace_flags_hex future_valsrr trace_flagsrs r:_get_traceparent_valuesz%_TraceContext._get_traceparent_valuess166rxxzB  ">CD D  " " $       d?G"LM M _ KKWY` a _!8qtvvw w#L1";/ q=>? ? a<=> >&7 "-s!2A"333r<cd}|D]:}|jds|dd}td|jdD}<|r|jd}| t |}nd}|jd}|rt j |}|jdd}|jDcic]3\}}|jd sd |d dzt j |5} }}|| ||fSdiddfScc}}w) Nzdd=r c3@K|]}|jddyw):r0N)r).0items r: z7_TraceContext._get_tracestate_values..sM$**S!,Ms;sop0000000000000000zt.z_dd.p.%sr)r[dictrrrOrrrF) ts_lddlist_memsampling_priority_tssampling_priority_ts_intrlpidrnroother_propagated_tagss r:_get_tracestate_valuesz$_TraceContext._get_tracestate_valuess& NH""5)#AB<M9LMM  N #%66#; #/+./C+D(+/(VVC[F&55f=66#12DSURZRZR\%HNA`a`l`lmq`r QqrU"M$@$@$CC% !%,-BFDP PT4' ' %s 2C9 C9Ntraceparent_sampledtracestate_sampling_priorityrcf| xr|dk(}|s|dk(r |r|dk\rd}|S|s|dk(r |r|dkrd}|S|}|S)a When the traceparent sampled flag is set, the Datadog sampling priority is either 1 or a positive value of sampling priority if propagated in tracestate. When the traceparent sampled flag is not set, the Datadog sampling priority is either 0 or a negative value of sampling priority if propagated in tracestate. When origin is "rum" and there is no sampling priority propagated in tracestate, the above rules do not apply. rumrr0r)rrrfrom_rum_wo_priorityrs r:_get_sampling_priorityz$_TraceContext._get_sampling_priorityss$@?SFeO%#q(15QUV5V ! ! %#q(15QTU5U ! ! !=   r<c> tt|}|tjdytj |\}}}t|i}tt|}tj|||||S#t tf$rtjdYywxYw)Nzno traceparent headerz%received invalid w3c traceparent: %s ) rC!_POSSIBLE_HTTP_HEADER_TRACEPARENTrjrlrrrzAssertionError exceptionr) _POSSIBLE_HTTP_HEADER_TRACESTATE _get_context)rArrr trace_flagrptss r:rz_TraceContext._extracts &'H'RBz 12,9,Q,QRT,U )Hgz $R( "#CW M))(GZTRRN+  MMA2 F s'A4A44%BBcn|i}d}|}|r|jdDcgc]}|j}}dj|}tjd|rt j d|n||t< tj|} | rI| \} } }} |j| j| r | |t<tj|| |}nt j d|t!|||||Scc}w#ttf$rt j d|d} YwxYw)N,z [^\x20-\x7E]+z&received invalid tracestate header: %rz3received invalid dd header value in tracestate: %r z9no dd list member in tracestate from incoming request: %rr)rrjoinresearchrjrlr*rrrrzupdaterFr$rr) rrrrrprrmemberrtracestate_valuesrrrs r:rz_TraceContext._get_contexts= <D& 24#?vFLLN?D?$Byy)2. BBG,.'(-(5(L(LT(R% %PaM(*?KK 5 ; ; =>6:23(5(L(LZYmou(v%IIY[]^/   3@":.-IISUWX(,%-sD?D 'D43D4ch|j}|r||t<|jdur,t|j|j xsd|t <yt|jvr;t|jtd}t|j||t <y|j|t <yy)NFrrN) _traceparent_HTTP_HEADER_TRACEPARENT _is_remoter/ _tracestater_HTTP_HEADER_TRACESTATEr$rrO)rrArrs r:rz_TraceContext._injectFs & & 02G, -&&%/3G ,,l.B.B.Ga4/0',*<*<<l001FGL3G H`H`bi3j/03?3K3K/0 r<r6)rrrrrrrrrOrrrrrrrr<r:rrZs-^))+4+4Z%(%(Ngk !  !@H  !W_`cWd ! !DSS$( ( TLLr<rc,eZdZedZedZy)_NOP_Propagatorcyr6rras r:rz_NOP_Propagator._extractZsr<c|Sr6r)rrAs r:rz_NOP_Propagator._injectas r<N)rrrrrrrr<r:rrYs( r<rcReZdZdZedZedZeddZedZy)HTTPPropagatorz0A HTTP Propagator using HTTP headers as carrier.cg}g}tjD]A}t|}|j|}|s |j ||j |C||fSr6)r_propagation_style_extract _PROP_STYLESrappend)normalized_headerscontexts styles_w_ctx prop_style propagatorrDs r:"_extract_configured_contexts_availz1HTTPPropagator._extract_configured_contexts_availssf  ;; 0J%j1J ))*<=G(##J/  0 %%r<c |d}g}|ddD]}||j|}|jr|jr|j|jk7rn|jt |j|j|j rdnd|t k(r |jjtdndd|d|t k(stt|}|s||jt<||_ |S)Nrr0r^terminated_context)reasoncontext_headers)rr4 attributes) indexrrrrrr"rrr*rCr _span_links)rrrprimary_contextlinksrD style_w_ctxrs r:_resolve_contextsz HTTPPropagator._resolve_contextss"1+| CG&x~~g'>?K7#3#38H8HOLdLd8d ((#*#<#ddtrace.tracer.sample is not available, unable to sample span.r}T)rDrjerrorhasattrddtracer, _local_rootcurrent_root_spanrr-rrrlr propagation_http_baggage_enabled_baggagerHr(_propagation_style_injectrYrr&rr'rr"r)rrAnon_active_span root_spanrJs r:injectzHTTPPropagator.injects,  &?+B+B,+V IIv''  +22L 7H %''..(*K*+77 #NN<<> $):):)L)L)T%%i0 IIV W  (L,@,@,H II:L I   2 2d :|?T?T?`#,, Q6B6K6KC6P,s23 Q %(H(H H  ' ' g > %)I)I I  " "< 9 &&*J*J J  # #L' : .&2R2R R  ! !, 8 Sr<cv|s tS |jDcic]\}}|j|}}}tjr[tj D]=}t |}|j|}tjdur t|||cS tStj|\}}|r7tj|||}tjdur t|||S tScc}}w#t$r#tjddYtSwxYw)aExtract a Context from HTTP headers into a new Context. For tracecontext propagation we extract tracestate headers for propagation even if another propagation style is specified before tracecontext, so as to always propagate other vendor's tracestate values by default. This is skipped if the tracer is configured to take the first style it matches. Here is an example from a web endpoint:: from ddtrace.propagation.http import HTTPPropagator def my_controller(url, headers): context = HTTPPropagator.extract(headers) if context: tracer.context_provider.activate(context) with tracer.trace('my_controller') as span: span.set_tag('http.url', url) :param dict headers: HTTP headers to extract tracing attributes. :return: New `Context` with propagated attributes. Tz2error while extracting context propagation headersrf)rrFr8r_propagation_extract_firstrrrr3rLrrr* Exceptionrjrl) rAnamerorrrrDrrs r:extractzHTTPPropagator.extracts009  [AH!QgdA$**,/!Q !Q00"("C"C#J!-j!9J(112DEG>>$F23EwO"N #$y*8)Z)Z[m)n&,,>>xWijG>>$F23EwO"N y/"R* [ IIJUYI Zy [s/D DA!D D *AD D D87D8r6) rrrrrrr*r8r=rr<r:rrpsT: & &>:9:9x11r<rr6)lrsystypingrrrrrrr r r0ddtrace._trace.spanr version_infortyping_extensionsrddtrace._trace._span_linkrddtrace._trace.contextrrrr constantsrrrinternal._tagsetrrrrrrinternal.compatr internal.constantsr!r"r#rr$r%rTr&r'r(r)r*internal.loggerr+internal.samplingr,r-r.internal.utils.httpr/_utilsr1rrjrHrrrrrrrrrrr rr;rrrrr7r8r`rrrrrrrcompileVERBOSErrCrrLrQrrWrYrrrrrobjectrrr<r:rPso $v).*A@-!#!007733)8DZ6D;<:43(?1:6# %+- =')'($$(&@"22F!G"23H"I+;