Merge "Revert "Add retries when loading keystone data and fetching endpoints""
This commit is contained in:
commit
7b606461e1
@ -12,7 +12,6 @@
|
|||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
from keystoneauth1 import access
|
from keystoneauth1 import access
|
||||||
from keystoneauth1 import exceptions as ksa_exceptions
|
|
||||||
from keystoneauth1.identity import access as access_plugin
|
from keystoneauth1.identity import access as access_plugin
|
||||||
from keystoneauth1.identity import generic
|
from keystoneauth1.identity import generic
|
||||||
from keystoneauth1 import loading as ks_loading
|
from keystoneauth1 import loading as ks_loading
|
||||||
@ -25,7 +24,6 @@ import oslo_messaging
|
|||||||
from oslo_middleware import request_id as oslo_request_id
|
from oslo_middleware import request_id as oslo_request_id
|
||||||
from oslo_utils import importutils
|
from oslo_utils import importutils
|
||||||
import six
|
import six
|
||||||
import tenacity
|
|
||||||
|
|
||||||
from heat.common import config
|
from heat.common import config
|
||||||
from heat.common import endpoint_utils
|
from heat.common import endpoint_utils
|
||||||
@ -55,15 +53,6 @@ TRUSTEE_CONF_GROUP = 'trustee'
|
|||||||
ks_loading.register_auth_conf_options(cfg.CONF, TRUSTEE_CONF_GROUP)
|
ks_loading.register_auth_conf_options(cfg.CONF, TRUSTEE_CONF_GROUP)
|
||||||
|
|
||||||
|
|
||||||
retry_on_connection_timeout = tenacity.retry(
|
|
||||||
stop=tenacity.stop_after_attempt(cfg.CONF.client_retry_limit+1),
|
|
||||||
wait=tenacity.wait_random(max=2),
|
|
||||||
retry=tenacity.retry_if_exception_type(
|
|
||||||
(ksa_exceptions.ConnectFailure,
|
|
||||||
ksa_exceptions.DiscoveryFailure)),
|
|
||||||
reraise=True)
|
|
||||||
|
|
||||||
|
|
||||||
def list_opts():
|
def list_opts():
|
||||||
trustee_opts = ks_loading.get_auth_common_conf_options()
|
trustee_opts = ks_loading.get_auth_common_conf_options()
|
||||||
trustee_opts.extend(ks_loading.get_auth_plugin_conf_options(
|
trustee_opts.extend(ks_loading.get_auth_plugin_conf_options(
|
||||||
@ -302,8 +291,6 @@ class RequestContext(context.RequestContext):
|
|||||||
|
|
||||||
|
|
||||||
class StoredContext(RequestContext):
|
class StoredContext(RequestContext):
|
||||||
|
|
||||||
@retry_on_connection_timeout
|
|
||||||
def _load_keystone_data(self):
|
def _load_keystone_data(self):
|
||||||
self._keystone_loaded = True
|
self._keystone_loaded = True
|
||||||
auth_ref = self.auth_plugin.get_access(self.keystone_session)
|
auth_ref = self.auth_plugin.get_access(self.keystone_session)
|
||||||
|
@ -24,7 +24,6 @@ import requests
|
|||||||
import six
|
import six
|
||||||
|
|
||||||
from heat.common import config
|
from heat.common import config
|
||||||
from heat.common import context
|
|
||||||
from heat.common import exception as heat_exception
|
from heat.common import exception as heat_exception
|
||||||
|
|
||||||
cfg.CONF.import_opt('client_retry_limit', 'heat.common.config')
|
cfg.CONF.import_opt('client_retry_limit', 'heat.common.config')
|
||||||
@ -94,7 +93,6 @@ class ClientPlugin(object):
|
|||||||
def url_for(self, **kwargs):
|
def url_for(self, **kwargs):
|
||||||
keystone_session = self.context.keystone_session
|
keystone_session = self.context.keystone_session
|
||||||
|
|
||||||
@context.retry_on_connection_timeout
|
|
||||||
def get_endpoint():
|
def get_endpoint():
|
||||||
return keystone_session.get_endpoint(**kwargs)
|
return keystone_session.get_endpoint(**kwargs)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user