def send(method):
def wrap(func):
def wrapped_f(*args, **kwargs):
- connect_retries = 30
- connect_retry_delay = 1
cloud_name = kwargs.pop('cloud_name')
+ connection_params = kwargs.pop('connection_params', {}) or {}
+ connect_retries = connection_params.get('connect_retries', 60)
+ connect_retry_delay = connection_params.get('connect_retry_delay',
+ 1)
if not cloud_name:
e = NoCredentials()
log.error('%s' % e)