mirror of
https://github.com/ansible-collections/google.cloud.git
synced 2025-04-09 04:10:27 -07:00
issue with async + decoders (#357)
Signed-off-by: Modular Magician <magic-modules@google.com>
This commit is contained in:
parent
0c2b6efe52
commit
7085a06925
3 changed files with 15 additions and 3 deletions
|
@ -1270,7 +1270,11 @@ def wait_for_operation(module, response):
|
||||||
return {}
|
return {}
|
||||||
status = navigate_hash(op_result, ['status'])
|
status = navigate_hash(op_result, ['status'])
|
||||||
wait_done = wait_for_completion(status, op_result, module)
|
wait_done = wait_for_completion(status, op_result, module)
|
||||||
return decode_response(fetch_resource(module, navigate_hash(wait_done, ['targetLink']), 'compute#instance'), module)
|
response = fetch_resource(module, navigate_hash(wait_done, ['targetLink']), 'compute#instance')
|
||||||
|
if response:
|
||||||
|
return decode_response(response, module)
|
||||||
|
else:
|
||||||
|
return {}
|
||||||
|
|
||||||
|
|
||||||
def wait_for_completion(status, op_result, module):
|
def wait_for_completion(status, op_result, module):
|
||||||
|
|
|
@ -1117,7 +1117,11 @@ def wait_for_operation(module, response):
|
||||||
return {}
|
return {}
|
||||||
status = navigate_hash(op_result, ['status'])
|
status = navigate_hash(op_result, ['status'])
|
||||||
wait_done = wait_for_completion(status, op_result, module)
|
wait_done = wait_for_completion(status, op_result, module)
|
||||||
return decode_response(fetch_resource(module, navigate_hash(wait_done, ['targetLink']), 'compute#instanceTemplate'), module)
|
response = fetch_resource(module, navigate_hash(wait_done, ['targetLink']), 'compute#instanceTemplate')
|
||||||
|
if response:
|
||||||
|
return decode_response(response, module)
|
||||||
|
else:
|
||||||
|
return {}
|
||||||
|
|
||||||
|
|
||||||
def wait_for_completion(status, op_result, module):
|
def wait_for_completion(status, op_result, module):
|
||||||
|
|
|
@ -419,7 +419,11 @@ def wait_for_operation(module, response):
|
||||||
return {}
|
return {}
|
||||||
status = navigate_hash(op_result, ['status'])
|
status = navigate_hash(op_result, ['status'])
|
||||||
wait_done = wait_for_completion(status, op_result, module)
|
wait_done = wait_for_completion(status, op_result, module)
|
||||||
return decode_response(fetch_resource(module, navigate_hash(wait_done, ['targetLink']), 'compute#targetPool'), module)
|
response = fetch_resource(module, navigate_hash(wait_done, ['targetLink']), 'compute#targetPool')
|
||||||
|
if response:
|
||||||
|
return decode_response(response, module)
|
||||||
|
else:
|
||||||
|
return {}
|
||||||
|
|
||||||
|
|
||||||
def wait_for_completion(status, op_result, module):
|
def wait_for_completion(status, op_result, module):
|
||||||
|
|
Loading…
Add table
Reference in a new issue