X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/96f5b2d78c60d1a16f51a269270d180b3f9a60a3..3bbb988777079718338e3e6cb9c6c9b5399be800:/sdk/python/arvados/keep.py?ds=sidebyside diff --git a/sdk/python/arvados/keep.py b/sdk/python/arvados/keep.py index 323251d3e9..46bd1cb464 100644 --- a/sdk/python/arvados/keep.py +++ b/sdk/python/arvados/keep.py @@ -165,7 +165,7 @@ class KeepBlockCache(object): self.ready.set() def size(self): - if self.content == None: + if self.content is None: return 0 else: return len(self.content) @@ -425,7 +425,10 @@ class KeepClient(object): if proxy is None: proxy = config.get('ARVADOS_KEEP_PROXY') if api_token is None: - api_token = config.get('ARVADOS_API_TOKEN') + if api_client is None: + api_token = config.get('ARVADOS_API_TOKEN') + else: + api_token = api_client.api_token elif api_client is not None: raise ValueError( "can't build KeepClient with both API client and token") @@ -473,14 +476,14 @@ class KeepClient(object): if not keep_services: raise arvados.errors.NoKeepServersError() - self.using_proxy = (keep_services[0].get('service_type') == - 'proxy') + self.using_proxy = any(ks.get('service_type') == 'proxy' + for ks in keep_services) - roots = (("http%s://%s:%d/" % - ('s' if f['service_ssl_flag'] else '', - f['service_host'], - f['service_port'])) - for f in keep_services) + roots = ("{}://[{}]:{:d}/".format( + 'https' if ks['service_ssl_flag'] else 'http', + ks['service_host'], + ks['service_port']) + for ks in keep_services) self.service_roots = sorted(set(roots)) _logger.debug(str(self.service_roots))