$Ii} SSKrSSKJr SSKJr SSKJrJr SSK J r J r J r J r SSKJr SSKJrJr SSKJrJr SS KJr SS KJr SS KJr \"5rS rS"S \S\ \S\ \\4S\ \\44Sjjr S#S\!S\"S\"S\4Sjjr#S \ \$\4S\4Sjr%S"Sjr&S\4Sjr'S\(4Sjr)Sr*S\"4Sjr+S\"4Sjr,\S\S\ S4Sj5r-\S\ S4S j5r.\S\ S4S!j5r/g)$N)contextmanager) import_module)escapesub)DictIterableSequenceUnion) ObjectProxy)contexttrace)"_SUPPRESS_HTTP_INSTRUMENTATION_KEY_SUPPRESS_INSTRUMENTATION_KEY)extract) StatusCode)TraceContextTextMapPropagatorsuppress_instrumentationobj attributesexistingreturnc0nU(aURU5 UH!n[XS5nUcM[U5X4'M# U$N)updategetattrstr)rrr extractedattrvalues I/venv/lib/python3.13/site-packages/opentelemetry/instrumentation/utils.pyextract_attributes_from_objectr!.sII"4(  !%jIO statusallow_redirect server_spanc8[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)r#r$r%s r http_status_to_status_coder,;sy fc " " | } } }   r"rc[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=Ts#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) r get_current_span INVALID_SPANrr attachSpanKindSERVER get_currentINTERNAL start_span) tracer span_namerBcontext_carriercontext_getterrtokenctx span_kindspans r _start_internal_or_server_spanrSqs0#"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"keysc'# [R"5nUHn[R"USU5nM [R"U5nSv [R"U5 g![R"U5 f=f7f),Suppress instrumentation within the context.TN)r rH set_valuerEdetach)rprPkeyrOs r _suppress_instrumentationrvsa    CT3/ NN3 E uusA BA+B+BBc#p# [[[5 Sv SSS5 g!,(df  g=f7frrN)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)TF)0 urllib.parserW contextlibr importlibrrerrtypingrrr r wraptr opentelemetryr r opentelemetry.contextrropentelemetry.propagateropentelemetry.tracer,opentelemetry.trace.propagation.tracecontextrr_rkanyrr!r)boolr,objectr=rSr]dictrbrhrmrorvrrzrlr"r rsw%#22( ,*+ , $ EI   "3- 37S>  #s(^    2-fck"-#-F 'T%S%4D  S Xd^  (4.x~r"