From eacb24d4e061cac27438062a2c5908aa8c3bfa8a Mon Sep 17 00:00:00 2001
From: nemanja-kovacevic-thinkit <nemanja.kovacevic@technologyfromsage.com>
Date: Tue, 19 Nov 2024 22:42:59 +0100
Subject: [PATCH] feat: set maxConcurrency on LambdaWorker DLQ

---
 lib/lambda-worker/lambda-worker.ts            |  1 +
 .../infra/lambda-worker/lambda-worker.test.ts | 24 +++++++++++++++++++
 2 files changed, 25 insertions(+)

diff --git a/lib/lambda-worker/lambda-worker.ts b/lib/lambda-worker/lambda-worker.ts
index bf9df48..0636dfc 100644
--- 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
index 27e503d..3c2bca1 100644
--- 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);
       });