`Qj xUdZddlmZddlmZddlmZddlmZddl m Z m Z ee Z de jfde jd edzd e j e jd efd Zde j$fde jd edzd e j&e jd dfdZd e j*fdZeae j*ed<gZee j*ed<ej6edZej;dD]Zej?Zd e j*fdZ de j*d dfdZ!y)a API for propagation of context. The propagators for the ``opentelemetry.propagators.composite.CompositePropagator`` can be defined via configuration in the ``OTEL_PROPAGATORS`` environment variable. This variable should be set to a comma-separated string of names of values for the ``opentelemetry_propagator`` entry point. For example, setting ``OTEL_PROPAGATORS`` to ``tracecontext,baggage`` (which is the default value) would instantiate ``opentelemetry.propagators.composite.CompositePropagator`` with 2 propagators, one of type ``opentelemetry.trace.propagation.tracecontext.TraceContextTextMapPropagator`` and other of type ``opentelemetry.baggage.propagation.W3CBaggagePropagator``. Notice that these propagator classes are defined as ``opentelemetry_propagator`` entry points in the ``pyproject.toml`` file of ``opentelemetry``. Example:: import flask import requests from opentelemetry import propagate PROPAGATOR = propagate.get_global_textmap() def get_header_from_flask_request(request, key): return request.headers.get_all(key) def set_header_into_requests_request(request: requests.Request, key: str, value: str): request.headers[key] = value def example_route(): context = PROPAGATOR.extract(get_header_from_flask_request, flask.request) request_to_downstream = requests.Request("GET", "http://httpbin.org/get") PROPAGATOR.inject( set_header_into_requests_request, request_to_downstream, context=context, ) session = requests.Session() session.send(request_to_downstream.prepare()) .. _Propagation API Specification: https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/context/api-propagators.md ) getLogger)environ)Context)OTEL_PROPAGATORS) compositetextmapNcarriercontextgetterreturnc:tj|||S)aZUses the configured propagator to extract a Context from the carrier. Args: 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. carrier: and 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: an optional Context to use. Defaults to root context if not set. )r )get_global_textmapextract)r r r s e/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/opentelemetry/propagate/__init__.pyrrBs$   ' ' ' HHsetterc<tj|||y)aUses the configured propagator to inject a Context into the carrier. Args: carrier: the medium used by Propagators to read values from and write values to. Should be paired with setter, which should know how to set header values on the carrier. context: An optional Context to use. Defaults to current context if not set. setter: An optional `Setter` object that can set values on the carrier. )r rN)rinject)r r rs rrrWs"Hrc tjt}|s-ddlm}ddlm}tj||gSddl m }g}|jdD]}|j}|jdk(r,tjdtjgcS |j!t#t%|d| j'tj|S#t($rt+d |d t,$rtj/d |wxYw) Nr)W3CBaggagePropagator)TraceContextTextMapPropagator) entry_points,nonezMOTEL_PROPAGATORS environment variable contains none, removing all propagatorsopentelemetry_propagator)groupnamez Propagator z5 not found. It is either misspelled or not installed.zFailed to load propagator: %s)rgetr!opentelemetry.baggage.propagationr,opentelemetry.trace.propagation.tracecontextrrCompositePropagator&opentelemetry.util._importlib_metadatarsplitstriplowerloggerdebugappendnextiterload StopIteration ValueError Exception exception) configuredrrr _propagators _propagators r_load_propagatorsr3ks:-.J   ,,.K.MOcOe-fgg57L!'', !'')    & ( LLh i004 4    $"D  8E_HTTP_TEXT_FORMAT propagatorsztracecontext,baggagerctSNr4rrrrs rhttp_text_formatc|ayr7r8)r:s rset_global_textmapr<s )r)"__doc__loggingrosropentelemetry.context.contextr#opentelemetry.environment_variablesropentelemetry.propagatorsrr__name__r&default_getterCarrierTGetterrdefault_setterSetterrTextMapPropagatorr3r4__annotations__r5listrenviron_propagatorsr# propagatorr$rr<r9rrrNs{2h1@8 8  #/6/E/EI   I t^I NN7++ ,I I.#/6/E/EI   I t^I NN7++ ,I I(*7744*7Z0A/B7,,B02 T'++ ,1!gkk"24JK%++C0$J!!#J$G55)//) )r