AspectPriority

packages/aws-cdk-lib/core/lib/removal-policies.ts

@@ -1,5 +1,5 @@
 import { IConstruct } from 'constructs';
-import { Aspects, IAspect } from './aspect';
+import { Aspects, IAspect, AspectPriority } from './aspect';
 import { CfnResource } from './cfn-resource';
 import { RemovalPolicy } from './removal-policy';
 
@@ -28,11 +28,16 @@ export interface RemovalPolicyProps {
    * @default false - do not overwrite user-specified policies
    */
   readonly overwrite?: boolean;
+
+  /**
+   * The priority to use when applying this aspect.
+   * If multiple aspects apply conflicting settings, the one with the higher priority wins.
+   *
+   * @default - AspectPriority.MUTATING
+   */
+  readonly priority?: number;
 }
 
-/**
- * The RemovalPolicyAspect handles applying a removal policy to resources
- */
 class RemovalPolicyAspect implements IAspect {
   constructor(
     private readonly policy: RemovalPolicy,
@@ -46,7 +51,6 @@ class RemovalPolicyAspect implements IAspect {
     if (!patterns || patterns.length === 0) {
       return false;
     }
-
     return patterns.includes(resourceType);
   }
 
@@ -103,7 +107,9 @@ export class RemovalPolicies {
    * @param props Configuration options
    */
   public apply(policy: RemovalPolicy, props: RemovalPolicyProps = {}) {
-    Aspects.of(this.scope).add(new RemovalPolicyAspect(policy, props));
+    Aspects.of(this.scope).add(new RemovalPolicyAspect(policy, props), {
+      priority: props.priority ?? AspectPriority.MUTATING,
+    });
   }
 
   /**

packages/aws-cdk-lib/core/test/removal-policies.test.ts

@@ -220,4 +220,18 @@ describe('removal-policys', () => {
     expect(bucket.cfnOptions.deletionPolicy).toBe('Retain');
     expect(table.cfnOptions.deletionPolicy).toBe('RetainExceptOnCreate');
   });
+
+  test('higher priority removal policy overrides lower priority removal policy', () => {
+    // GIVEN
+    const stack = new Stack();
+    const resource = new TestResource(stack, 'PriorityResource');
+
+    // WHEN
+    RemovalPolicies.of(stack).retainOnUpdateOrDelete({ priority: 250 });
+    RemovalPolicies.of(stack).destroy({ priority: 10 });
+
+    // THEN
+    synthesize(stack);
+    expect(resource.cfnOptions.deletionPolicy).toBe('Delete');
+  });
 });