removing unneeded max_concurrency arg

brifordwylie · brifordwylie · commit fac324cb46bc · 2025-10-28T10:48:05.000-06:00
diff --git a/aws_setup/workbench_compute/workbench_compute/workbench_compute_stack.py b/aws_setup/workbench_compute/workbench_compute/workbench_compute_stack.py
@@ -208,7 +208,7 @@ def create_batch_trigger_lambda(self) -> lambda_.Function:
         # Connect SQS to Lambda
         batch_trigger_lambda.add_event_source(
             lambda_events.SqsEventSource(
-                self.ml_pipeline_queue, batch_size=1, max_concurrency=5  # Limit parallel Batch job submissions
+                self.ml_pipeline_queue, batch_size=1  # One message at a time for precise error handling
             )
         )
         return batch_trigger_lambda

Original file line number	Diff line number	Diff line change
`@@ -208,7 +208,7 @@ def create_batch_trigger_lambda(self) -> lambda_.Function:`
`208`	`208`	`# Connect SQS to Lambda`
`209`	`209`	`batch_trigger_lambda.add_event_source(`
`210`	`210`	`lambda_events.SqsEventSource(`
`211`		`- self.ml_pipeline_queue, batch_size=1, max_concurrency=5 # Limit parallel Batch job submissions`
	`211`	`+ self.ml_pipeline_queue, batch_size=1 # One message at a time for precise error handling`
`212`	`212`	`)`
`213`	`213`	`)`
`214`	`214`	`return batch_trigger_lambda`