Created new steps to check if there are any running state machine exe…

…cutions and stop any concurrent runs.
slalom · Jun 5, 2024 · 2a2e717 · 2a2e717
1 parent bbe8c42
commit 2a2e717
Showing 1 changed file with 25 additions and 1 deletion.
diff --git a/catalog/aws/singer-taps/step-functions.tf b/catalog/aws/singer-taps/step-functions.tf
@@ -6,8 +6,32 @@ locals {
   "Version": "1.0",
   "Comment": "Run Sync (ECS Fargate: ${tap_spec.image})",
   "TimeoutSeconds": ${var.timeout_hours * (60 * 60)},
-  "StartAt": "RunTask",
+  "StartAt": "ListRunningExecutions",
   "States": {
+    "ListRunningExecutions": {
+      "Type": "Task",
+      "Parameters": {
+        "StateMachineArn.$": "$$.StateMachine.Id",
+        "StatusFilter": "RUNNING"
+      },
+      "Resource": "arn:aws:states:::aws-sdk:sfn:listExecutions",
+      "Next": "IsExecutionCountGreaterThan1",
+      "ResultPath": "$.runningExecutionsCount",
+      "ResultSelector": {
+        "runningExecutionsCount.$": "States.ArrayLength($.Executions)"
+      }
+    },
+    "IsExecutionCountGreaterThan1": {
+      "Type": "Choice",
+      "Choices": [
+        {
+          "Variable": "$.runningExecutionsCount.runningExecutionsCount",
+          "NumericGreaterThan": 1,
+          "Next": "NotifyOnError"
+        }
+      ],
+      "Default": "RunTask"
+    },
     "RunTask": {
       "Type": "Task",
       "Resource": "arn:aws:states:::ecs:runTask.sync",