File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1919 RequestOptions ,
2020 not_given ,
2121)
22- from ._utils import is_given , get_async_library
22+ from ._utils import (
23+ is_given ,
24+ is_mapping_t ,
25+ get_async_library ,
26+ )
2327from ._compat import cached_property
2428from ._version import __version__
2529from ._streaming import Stream as Stream , AsyncStream as AsyncStream
@@ -115,6 +119,15 @@ def __init__(
115119 if base_url is None :
116120 base_url = f"https://api.runloop.ai"
117121
122+ custom_headers_env = os .environ .get ("RUNLOOP_CUSTOM_HEADERS" )
123+ if custom_headers_env is not None :
124+ parsed : dict [str , str ] = {}
125+ for line in custom_headers_env .split ("\n " ):
126+ colon = line .find (":" )
127+ if colon >= 0 :
128+ parsed [line [:colon ].strip ()] = line [colon + 1 :].strip ()
129+ default_headers = {** parsed , ** (default_headers if is_mapping_t (default_headers ) else {})}
130+
118131 super ().__init__ (
119132 version = __version__ ,
120133 base_url = base_url ,
@@ -388,6 +401,15 @@ def __init__(
388401 if base_url is None :
389402 base_url = f"https://api.runloop.ai"
390403
404+ custom_headers_env = os .environ .get ("RUNLOOP_CUSTOM_HEADERS" )
405+ if custom_headers_env is not None :
406+ parsed : dict [str , str ] = {}
407+ for line in custom_headers_env .split ("\n " ):
408+ colon = line .find (":" )
409+ if colon >= 0 :
410+ parsed [line [:colon ].strip ()] = line [colon + 1 :].strip ()
411+ default_headers = {** parsed , ** (default_headers if is_mapping_t (default_headers ) else {})}
412+
391413 super ().__init__ (
392414 version = __version__ ,
393415 base_url = base_url ,
You can’t perform that action at this time.
0 commit comments