o Y۷ib@sjddlZddlZddlmZddlmZmZGdddeejeefZ GdddeeeefZ dS)N)MutableMapping)GetterSetterc@sfeZdZdZddZdejeefdedejej efddZ dejeefdej efd d Z d S) EnvironmentGetteraGetter implementation for extracting context and baggage from environment variables. EnvironmentGetter creates a case-insensitive lookup from the current environment variables at initialization time and provides simple data access without validation. Per the OpenTelemetry specification, environment variables are treated as immutable within a process. For environments where context-carrying environment variables change between logical requests (e.g., AWS Lambda's _X_AMZN_TRACE_ID), create a new EnvironmentGetter instance at the start of each request. Example usage: getter = EnvironmentGetter() traceparent = getter.get({}, "traceparent") cCsddtjD|_dS)NcSsi|] \}}||qS)lower).0kvrr[/home/ubuntu/vllm_env/lib/python3.10/site-packages/opentelemetry/propagators/_envcarrier.py )sz.EnvironmentGetter.__init__..)osenvironitemscarrier)selfrrr __init__&s zEnvironmentGetter.__init__rkeyreturncCs@|j|}|durdSt|tjrt|tst|S|gS)aIGet a value from the environment carrier for the given key. Args: carrier: Not used; maintained for interface compatibility with Getter[CarrierT] key: The key to look up (case-insensitive) Returns: A list with a single string value if the key exists, None otherwise. N)rgetr isinstancetypingIterablestrlist)rrrvalrrr r-s  zEnvironmentGetter.getcCst|jS)zGet all keys from the environment carrier. Args: carrier: Not used; maintained for interface compatibility with Getter[CarrierT] Returns: List of all environment variable keys (lowercase). )rrkeys)rrrrr r@s zEnvironmentGetter.keysN) __name__ __module__ __qualname____doc__rrMappingrOptionalListrrrrrr rs  &rc@s2eZdZdZdeeefdededdfddZdS) EnvironmentSetteraSetter implementation for building environment variable dictionaries. EnvironmentSetter builds a dictionary of environment variables that can be passed to utilities like subprocess.run() Example usage: setter = EnvironmentSetter() env_vars = {} setter.set(env_vars, "traceparent", "00-trace-id-span-id-01") subprocess.run(myCommand, env=env_vars) rrvaluerNcCs|||<dS)zSet a value in the carrier dictionary for the given key. Args: carrier: Dictionary to store environment variables key: The key to set (will be converted to uppercase) value: The value to set N)upper)rrrr%rrr setYs zEnvironmentSetter.set)rrrr rrr'rrrr r$Ls r$) r rcollections.abcr!opentelemetry.propagators.textmaprrr!rrr$rrrr s   6