feat: set maxConcurrency on LambdaWorker DLQ

techfromsage · Nov 20, 2024 · 78fa628 · 78fa628
1 parent fb0ee04
commit 78fa628
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 0 deletions.
diff --git a/lib/lambda-worker/lambda-worker.ts b/lib/lambda-worker/lambda-worker.ts
@@ -148,6 +148,7 @@ export class LambdaWorker extends Construct {
       new SqsEventSource(lambdaDLQ, {
         enabled: false,
         batchSize: 1,
+        maxConcurrency: props.lambdaProps.queueMaxConcurrency,
       }),
     );
 

diff --git a/test/infra/lambda-worker/lambda-worker.test.ts b/test/infra/lambda-worker/lambda-worker.test.ts
@@ -103,6 +103,32 @@ describe("LambdaWorker", () => {
           VisibilityTimeout: 1500, // 5 (default max receive count) * 300 (lambda timeout)
           MessageRetentionPeriod: 1209600, // 14 days
         });
+
+        Template.fromStack(stack).hasResourceProperties("AWS::Lambda::EventSourceMapping", {
+          Enabled: true,
+          BatchSize: 1,
+          ScalingConfig: {
+            MaximumConcurrency: 5
+          },
+        });
+      });
+
+      test("provisions Lambda EventSourceMapping", () => {
+        Template.fromStack(stack).hasResourceProperties("AWS::Lambda::EventSourceMapping", {
+          Enabled: true,
+          BatchSize: 1,
+          ScalingConfig: {
+            MaximumConcurrency: 5
+          },
+        });
+
+        Template.fromStack(stack).hasResourceProperties("AWS::Lambda::EventSourceMapping", {
+          Enabled: false,
+          BatchSize: 1,
+          ScalingConfig: {
+            MaximumConcurrency: 5
+          },
+        });
       });
 
       test("provisions three alarms", () => {