mirror of
https://github.com/ansible-collections/google.cloud.git
synced 2025-04-09 12:20:27 -07:00
Adding fetch back on certain places.
This commit is contained in:
parent
2cc62e1db7
commit
75dd36f715
2 changed files with 8 additions and 8 deletions
|
@ -189,10 +189,10 @@ def main():
|
||||||
if fetch:
|
if fetch:
|
||||||
if state == 'present':
|
if state == 'present':
|
||||||
if is_different(module, fetch):
|
if is_different(module, fetch):
|
||||||
fetch = update(module, self_link(module), kind)
|
fetch = update(module, self_link(module), kind, fetch)
|
||||||
changed = True
|
changed = True
|
||||||
else:
|
else:
|
||||||
delete(module, self_link(module), kind)
|
delete(module, self_link(module), kind, fetch)
|
||||||
fetch = {}
|
fetch = {}
|
||||||
changed = True
|
changed = True
|
||||||
else:
|
else:
|
||||||
|
@ -215,7 +215,7 @@ def create(module, link, kind):
|
||||||
return fetch_wrapped_resource(module, 'dns#resourceRecordSet', 'dns#resourceRecordSetsListResponse', 'rrsets')
|
return fetch_wrapped_resource(module, 'dns#resourceRecordSet', 'dns#resourceRecordSetsListResponse', 'rrsets')
|
||||||
|
|
||||||
|
|
||||||
def update(module, link, kind):
|
def update(module, link, kind, fetch):
|
||||||
change = create_change(fetch, updated_record(module), module)
|
change = create_change(fetch, updated_record(module), module)
|
||||||
change_id = int(change['id'])
|
change_id = int(change['id'])
|
||||||
if change['status'] == 'pending':
|
if change['status'] == 'pending':
|
||||||
|
@ -223,7 +223,7 @@ def update(module, link, kind):
|
||||||
return fetch_wrapped_resource(module, 'dns#resourceRecordSet', 'dns#resourceRecordSetsListResponse', 'rrsets')
|
return fetch_wrapped_resource(module, 'dns#resourceRecordSet', 'dns#resourceRecordSetsListResponse', 'rrsets')
|
||||||
|
|
||||||
|
|
||||||
def delete(module, link, kind):
|
def delete(module, link, kind, fetch):
|
||||||
change = create_change(fetch, None, module)
|
change = create_change(fetch, None, module)
|
||||||
change_id = int(change['id'])
|
change_id = int(change['id'])
|
||||||
if change['status'] == 'pending':
|
if change['status'] == 'pending':
|
||||||
|
|
|
@ -632,10 +632,10 @@ def main():
|
||||||
if fetch:
|
if fetch:
|
||||||
if state == 'present':
|
if state == 'present':
|
||||||
if is_different(module, fetch):
|
if is_different(module, fetch):
|
||||||
fetch = update(module, self_link(module), kind)
|
fetch = update(module, self_link(module), kind, fetch)
|
||||||
changed = True
|
changed = True
|
||||||
else:
|
else:
|
||||||
delete(module, self_link(module), kind)
|
delete(module, self_link(module), kind, fetch)
|
||||||
fetch = {}
|
fetch = {}
|
||||||
changed = True
|
changed = True
|
||||||
else:
|
else:
|
||||||
|
@ -655,12 +655,12 @@ def create(module, link, kind):
|
||||||
return wait_for_operation(module, auth.post(link, resource_to_request(module)))
|
return wait_for_operation(module, auth.post(link, resource_to_request(module)))
|
||||||
|
|
||||||
|
|
||||||
def update(module, link, kind):
|
def update(module, link, kind, fetch):
|
||||||
auth = GcpSession(module, 'sql')
|
auth = GcpSession(module, 'sql')
|
||||||
return wait_for_operation(module, auth.put(link, resource_to_request(module)))
|
return wait_for_operation(module, auth.put(link, resource_to_request(module)))
|
||||||
|
|
||||||
|
|
||||||
def delete(module, link, kind):
|
def delete(module, link, kind, fetch):
|
||||||
auth = GcpSession(module, 'sql')
|
auth = GcpSession(module, 'sql')
|
||||||
return wait_for_operation(module, auth.delete(link))
|
return wait_for_operation(module, auth.delete(link))
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue