VixSSKJr SSKrSSKJr SSKJr SSKJ r J r SSK J r J r JrJr SSKJr SSKJrJr SS KJrJr SS KJr SS KJr SS KJr \"5rS rSSSjjr SSSjjr!SSjr"SSjr#SSjr$S Sjr%Sr&S!Sjr'S!Sjr(\S"Sj5r)\S#Sj5r*\S#Sj5r+g)$) annotationsN)contextmanager) import_module)escapesub)AnyDict GeneratorSequence) ObjectProxy)contexttrace)"_SUPPRESS_HTTP_INSTRUMENTATION_KEY_SUPPRESS_INSTRUMENTATION_KEY)extract) StatusCode)TraceContextTextMapPropagatorsuppress_instrumentationc0nU(aURU5 UH!n[XS5nUcM[U5X4'M# U$N)updategetattrstr)obj attributesexisting extractedattrvalues v/home/james-whalen/.local/share/pipx/venvs/semgrep/lib/python3.13/site-packages/opentelemetry/instrumentation/utils.pyextract_attributes_from_objectr!0sI!#I"4(  !%jIO c8[U[5(d[R$US:a[R$US::a[R$US::aU(a[R$US::aU(a[R$[R$)zqConverts an HTTP status code to an OpenTelemetry canonical status code Args: status (int): HTTP status code di+ii) isinstanceintrUNSETERROR)statusallow_redirect server_spans r http_status_to_status_coder,=sy fc " " | } } }   r"c[U[5(a,URSS5up#[ U5n[ XS5n[ XS5nU(a?[U[5(a)[US 5(a[XUR5 gggg![an[ SUS35UeSnAff=f![an[ SUSUS35UeSnAff=f) a9Given a function that was wrapped by wrapt.wrap_function_wrapper, unwrap it The object containing the function to unwrap may be passed as dotted module path string. Args: obj: Object that holds a reference to the wrapped function or dotted import path as string attr (str): Name of the wrapped function .zCannot parse 'z' as dotted import pathNzCannot import 'z' from '' __wrapped__) r%rrsplit ValueError ImportErrorrrAttributeErrorr hasattrsetattrr1)rr module_path class_nameexcmodulefuncs r unwrapr=Vs#s &)jja&8 #K {+ &-C 3d #D 4--'$ 2N2N4++,3O-t  %<=   !*XfXQ?  s.B B7 B4B//B47 CCCcVS=n=px[R"5[RLa:[X4S9n[R "U5n[R RnO/[R"5n[R RnURUUUUUS9n X4$)aReturns internal or server span along with the token which can be used by caller to reset context Args: tracer : tracer in use by given instrumentation library span_name (string): name of the span start_time : start time of the span context_carrier : object which contains values that are used to construct a Context. This object must be paired with an appropriate getter which understands how to extract a value from it. context_getter : an object which contains a get function that can retrieve zero or more values from the carrier and a keys function that can get all the keys from carrier. N)getter)namer kind start_timer) rget_current_span INVALID_SPANrr attachSpanKindSERVER get_currentINTERNAL start_span) tracer span_namerBcontext_carriercontext_getterrtokenctx span_kindspans r _start_internal_or_server_spanrSss0#"E"C 5#5#55o=s#NN)) !!#NN++       D ;r"c[U[[45(dU$[RR U5nUR SS5$)N%z%%)r%rbytesurllibparsequotereplace)squoteds r _url_quoter]s? a#u & & \\   "F >>#t $$r"c40n[RU5 U$)zg Return the OpenTelemetry Trace and Span IDs if Span ID is set in the OpenTelemetry execution context. ) propagatorinject)_headerss r _get_opentelemetry_valuesrbs "Hh Or"c8[[U5US3SU5$)Nz(?!$))rr) python_path directorypath_separators r _python_path_without_directoryrhs*  9  ~.e4  r"c[R"[5=(d [R"[5(+$r)r get_valuer#_SUPPRESS_INSTRUMENTATION_KEY_PLAINr"r is_instrumentation_enabledrms078 B   @ A r"cb[5=(a [R"[5(+$r)rmr rjrrlr"r is_http_instrumentation_enabledros' % ' 0A0A*1-r"c'0# [R"5nUHn[R"USU5nM [R"U5nSv U(a[R"U5 gg!U(a[R"U5 ff=f7f),Suppress instrumentation within the context.TN)r rH set_valuerEdetach)keysrPkeyrOs r _suppress_instrumentationrvsq    CT3/ NN3 E"  NN5 ! 5 NN5 ! sA BA3B3 BBc#p# [[[5 Sv SSS5 g!,(df  g=f7frqN)rvrrkrlr"r rrs) #%'J     s6% 6 36c#f# [[5 Sv SSS5 g!,(df  g=f7frx)rvrrlr"r suppress_http_instrumentationrzs ##E F  G F Fs1  1 .1r)rrrz Sequence[str]rzDict[str, str] | NonereturnzDict[str, str])TF)r)r&r*boolr+r|r{r)robjectrr)r[rr{r)r{zdict[str, Any])r{r|)rtrr{Generator[None])r{r~), __future__r urllib.parserW contextlibr importlibrrerrtypingrr r r wraptr opentelemetryr ropentelemetry.contextrropentelemetry.propagateropentelemetry.tracer,opentelemetry.trace.propagation.tracecontextrr_rkr!r,r=rSr]rbrhrmrorvrrzrlr"r rs #%#11( ,*+ , $ LP   ' 3H     2-F 'T%  " "r"