in azure/datalake/store/lib.py [0:0]
def session(self):
bearer_token = self.get_refreshed_bearer_token()
try:
s = self.local.session
s.headers['Authorization'] = "Bearer " + bearer_token
except AttributeError:
s = None
if not s:
adapter = requests.adapters.HTTPAdapter(
pool_connections=MAX_POOL_CONNECTIONS,
pool_maxsize=MAX_POOL_CONNECTIONS)
s = requests.Session()
s.mount(self.url, adapter)
s.headers['Authorization'] = "Bearer " + bearer_token
self.local.session = s
return s