return False
-def named_checker(resource, ref, cloud_name):
+def named_checker(resource, ref, cloud_name, **kwargs):
resp_key = response_keys[resource]
resp = resource_lists[resource](
- name=ref, cloud_name=cloud_name)[resp_key]
+ name=ref, cloud_name=cloud_name, **kwargs)[resp_key]
if len(resp) == 0:
raise common.ResourceNotFound(resp_key, ref)
elif len(resp) > 1:
return resp[0]['id']
-def nameless_checker(resource, ref, cloud_name):
+def nameless_checker(resource, ref, cloud_name, **kwargs):
item_id = None
resp_key = response_keys[resource]
- resp = resource_lists[resource](cloud_name=cloud_name)[resp_key]
+ resp = resource_lists[resource](
+ cloud_name=cloud_name, **kwargs)[resp_key]
for item in resp:
if item["name"] == ref:
if item_id is not None:
def wrapped_f(*args, **kwargs):
results = []
args_start = 0
+ connection_params = kwargs.pop('connection_params', {}) or {}
for index, (resource, arg_name) in enumerate(
resource_arg_name_pairs):
if arg_name in kwargs:
results.append(ref)
else:
# Then we have name not uuid
- res = name_checkers[resource](resource, ref, cloud_name)
+ res = name_checkers[resource](resource, ref, cloud_name,
+ connection_params=connection_params)
results.append(res)
results.extend(args[args_start:])
return func(*results, **kwargs)
return wrapped_f
- return wrap
\ No newline at end of file
+ return wrap