diff --git a/lib/ansible/modules/cloud/amazon/s3_lifecycle.py b/lib/ansible/modules/cloud/amazon/s3_lifecycle.py index 2acd5d15b8..401debbc3a 100644 --- a/lib/ansible/modules/cloud/amazon/s3_lifecycle.py +++ b/lib/ansible/modules/cloud/amazon/s3_lifecycle.py @@ -207,7 +207,7 @@ def create_lifecycle_rule(client, module): noncurrent_version_transition_days = module.params.get("noncurrent_version_transition_days") noncurrent_version_transitions = module.params.get("noncurrent_version_transitions") noncurrent_version_storage_class = module.params.get("noncurrent_version_storage_class") - prefix = module.params.get("prefix") + prefix = module.params.get("prefix") or "" rule_id = module.params.get("rule_id") status = module.params.get("status") storage_class = module.params.get("storage_class") @@ -280,7 +280,9 @@ def create_lifecycle_rule(client, module): if current_lifecycle_rules: # If rule ID exists, use that for comparison otherwise compare based on prefix for existing_rule in current_lifecycle_rules: - if rule['Filter']['Prefix'] == existing_rule['Filter']['Prefix']: + if rule.get('ID') == existing_rule.get('ID') and rule['Filter']['Prefix'] != existing_rule.get('Filter', {}).get('Prefix', ''): + existing_rule.pop('ID') + elif rule_id is None and rule['Filter']['Prefix'] == existing_rule.get('Filter', {}).get('Prefix', ''): existing_rule.pop('ID') if rule.get('ID') == existing_rule.get('ID'): changed_, appended_ = update_or_append_rule(rule, existing_rule, purge_transitions, lifecycle_configuration) @@ -361,9 +363,9 @@ def merge_transitions(updated_rule, updating_rule): # in updating_rule to updated_rule updated_transitions = {} updating_transitions = {} - for transition in updated_rule['Transitions']: + for transition in updated_rule.get('Transitions', []): updated_transitions[transition['StorageClass']] = transition - for transition in updating_rule['Transitions']: + for transition in updating_rule.get('Transitions', []): updating_transitions[transition['StorageClass']] = transition for storage_class, transition in updating_transitions.items(): if updated_transitions.get(storage_class) is None: diff --git a/test/integration/targets/s3_lifecycle/tasks/main.yml b/test/integration/targets/s3_lifecycle/tasks/main.yml index 0214f889c7..f6dc2ab386 100644 --- a/test/integration/targets/s3_lifecycle/tasks/main.yml +++ b/test/integration/targets/s3_lifecycle/tasks/main.yml @@ -30,7 +30,7 @@ s3_lifecycle: name: "{{ resource_prefix }}-testbucket-ansible" expiration_days: 300 - prefix: /pre + prefix: '' <<: *aws_connection_info register: output @@ -42,7 +42,6 @@ s3_lifecycle: name: "{{ resource_prefix }}-testbucket-ansible" expiration_days: 300 - prefix: /pre <<: *aws_connection_info register: output