diff --git a/plugins/modules/gcp_dns_resource_record_set.py b/plugins/modules/gcp_dns_resource_record_set.py index 5d67eb4..efb3fbf 100644 --- a/plugins/modules/gcp_dns_resource_record_set.py +++ b/plugins/modules/gcp_dns_resource_record_set.py @@ -189,10 +189,10 @@ def main(): if fetch: if state == 'present': if is_different(module, fetch): - fetch = update(module, self_link(module), kind) + fetch = update(module, self_link(module), kind, fetch) changed = True else: - delete(module, self_link(module), kind) + delete(module, self_link(module), kind, fetch) fetch = {} changed = True else: @@ -215,7 +215,7 @@ def create(module, link, kind): 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_id = int(change['id']) if change['status'] == 'pending': @@ -223,7 +223,7 @@ def update(module, link, kind): 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_id = int(change['id']) if change['status'] == 'pending': diff --git a/plugins/modules/gcp_sql_instance.py b/plugins/modules/gcp_sql_instance.py index 925c96f..0ba7705 100644 --- a/plugins/modules/gcp_sql_instance.py +++ b/plugins/modules/gcp_sql_instance.py @@ -632,10 +632,10 @@ def main(): if fetch: if state == 'present': if is_different(module, fetch): - fetch = update(module, self_link(module), kind) + fetch = update(module, self_link(module), kind, fetch) changed = True else: - delete(module, self_link(module), kind) + delete(module, self_link(module), kind, fetch) fetch = {} changed = True else: @@ -655,12 +655,12 @@ def create(module, link, kind): 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') 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') return wait_for_operation(module, auth.delete(link))