feat: set maxConcurrency on LambdaWorker DLQ (#92)

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

Hide file tree

Showing 2 changed files with 25 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
@@ -105,6 +105,30 @@ describe("LambdaWorker", () => {
         });
       });
 
+      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", () => {
         Template.fromStack(stack).resourceCountIs("AWS::CloudWatch::Alarm", 3);
       });