X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/27fe76f518db97633148657ff1e1610095be11fa..11377b3b6eb9544b9d9bcabab8de495f6e6fcaa4:/sdk/python/arvados/safeapi.py diff --git a/sdk/python/arvados/safeapi.py b/sdk/python/arvados/safeapi.py index 32cb2a543d..5c8a836939 100644 --- a/sdk/python/arvados/safeapi.py +++ b/sdk/python/arvados/safeapi.py @@ -1,13 +1,23 @@ -import threading -import api -import keep -import config +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: Apache-2.0 + +from __future__ import absolute_import + +from builtins import object import copy +import threading + +import arvados +import arvados.keep as keep +import arvados.config as config class ThreadSafeApiCache(object): - """Threadsafe wrapper for API objects. This stores and returns a different api - object per thread, because httplib2 which underlies apiclient is not - threadsafe. + """Threadsafe wrapper for API objects. + + This stores and returns a different api object per thread, because httplib2 + which underlies apiclient is not threadsafe. + """ def __init__(self, apiconfig=None, keep_params={}): @@ -19,7 +29,7 @@ class ThreadSafeApiCache(object): def localapi(self): if 'api' not in self.local.__dict__: - self.local.api = api.api('v1', False, apiconfig=self.apiconfig) + self.local.api = arvados.api_from_config('v1', apiconfig=self.apiconfig) return self.local.api def __getattr__(self, name):