Allow worker_id override using environment variable

This commit is contained in:
allegroai 2020-05-22 10:20:43 +03:00
parent 3491646ea9
commit 63ca84a84f

View File

@ -145,7 +145,7 @@ class Session(TokenManager):
http_retries_config["status_forcelist"] = self._retry_codes
self.__http_session = get_http_session_with_retry(**http_retries_config)
self.__worker = worker or gethostname()
self.__worker = worker or self.get_worker_host_name()
self.__max_req_size = self.config.get("api.http.max_req_size", None)
if not self.__max_req_size:
@ -530,6 +530,11 @@ class Session(TokenManager):
return version_tuple(cls.api_version) >= version_tuple(str(min_api_version))
@classmethod
def get_worker_host_name(cls):
from ...config import dev_worker_name
return dev_worker_name() or gethostname()
def _do_refresh_token(self, old_token, exp=None):
""" TokenManager abstract method implementation.
Here we ignore the old token and simply obtain a new token.