AWS Step Functions：并行分支任一完成后执行StateC的配置方法

要实现任一分支完成（无论成功或失败）后立即执行StateC，无需等待另一分支，你需要调整Parallel状态的配置，并为每个分支添加错误捕获逻辑，具体步骤如下：

1. 给Parallel状态添加CompletionCount参数 #

在Parallel状态中设置CompletionCount: 1，该参数指定只要有1个分支成功完成，就立即触发后续的StateC，无需等待所有分支结束。

2. 为每个分支添加错误捕获逻辑 #

默认情况下，如果分支中的任务失败，会导致整个Parallel状态失败，后续的StateC不会执行。因此需要给每个分支的任务添加Catch配置，捕获所有错误并将分支标记为“完成”，确保Parallel状态能识别该分支已结束。

修改后的ASL示例 #

{
  "States": {
    "ParallelState": {
      "Type": "Parallel",
      "CompletionCount": 1,
      "Branches": [
        {
          "StartAt": "StateA",
          "States": {
            "StateA": {
              "Type": "Task",
              "Resource": "arn:aws:lambda:us-east-1:123456789012:function:StateA",
              "End": true,
              "Catch": [
                {
                  "ErrorEquals": ["States.ALL"],
                  "Next": "MarkBranchComplete"
                }
              ]
            },
            "MarkBranchComplete": {
              "Type": "Pass",
              "Result": {"status": "completed"},
              "End": true
            }
          }
        },
        {
          "StartAt": "StateB",
          "States": {
            "StateB": {
              "Type": "Task",
              "Resource": "arn:aws:lambda:us-east-1:123456789012:function:StateB",
              "End": true,
              "Catch": [
                {
                  "ErrorEquals": ["States.ALL"],
                  "Next": "MarkBranchComplete"
                }
              ]
            },
            "MarkBranchComplete": {
              "Type": "Pass",
              "Result": {"status": "completed"},
              "End": true
            }
          }
        }
      ],
      "Next": "StateC"
    },
    "StateC": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:StateC",
      "End": true
    }
  }
}

关键逻辑说明 #

• CompletionCount: 1：让Parallel状态在第一个分支完成时立即进入下一个状态，不再等待其他分支。
• Catch配置：捕获分支中所有类型的错误（States.ALL），跳转到MarkBranchComplete Pass状态。这个状态会返回一个成功结果，让Parallel状态认为该分支已正常完成，满足CompletionCount的触发条件。
• 未完成的分支：即使StateC已经执行，另一个未完成的分支会继续运行，但不会影响StateC的执行流程。

内容的提问来源于stack exchange，提问作者Mohamed Tleis