StepFunctionsでネストしたワークフローのRedrive挙動確認

quo1987 4ヶ月前

テンプレートで提供されているこれを使う。

quo1987 4ヶ月前に更新

親ステートマシンからのRedrive

どちらも同じコードが使われているが1つ目はコールバック不要、2つ目はコールバック必要となっているので、コールバックの処理を削除してタイムアウトさせてみる。

console.log('Loading function');
const AWS = require('aws-sdk');
exports.lambda_handler = (event, context, callback) => {
    console.log('event ' + JSON.stringify(event));
    console.log('context ' + JSON.stringify(context));

    const taskToken = event.TaskToken;
    const message = event.Message;

    const params = {
        taskToken: taskToken,
        output: "\"" + message + "\""
    }

    const stepfunctions = new AWS.StepFunctions();
    callback(null)
    // stepfunctions.sendTaskSuccess(params, function(err, data) {
    //     if (err) {
    //         console.log("Error", err);
    //         callback(null, err)
    //     } else {
    //         console.log("Success", data);
    //         callback(null);
    //     }
    // });
}

{
          "StartAt": "Start new workflow and wait for callback",
          "States": {
            "Start new workflow and wait for callback": {
              "Comment": "Start an execution and wait for it to call back with a task token",
              "Type": "Task",
              "Resource": "arn:aws:states:::states:startExecution.waitForTaskToken",
              "Parameters": {
                "StateMachineArn": "arn:aws:states:ap-northeast-1:188970983837:stateMachine:NestingPatternAnotherStateMachine-jnTiEDCysncq",
                "Input": {
                  "NeedCallback": true,
                  "AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID.$": "$$.Execution.Id",
                  "TaskToken.$": "$$.Task.Token"
                }
              },
              "End": true,
              "TimeoutSeconds": 30
            }
          }
        }

親側はエラー

子は正常終了

Redriveすると、同様に失敗する。

期待通り正常終了した片側のワークフローは実行されず、失敗したワークフローのみ再実行される。

quo1987 4ヶ月前に更新

子のステートマシンからのRdrive

子のステートマシンからRedriveするとどうなる？
Callback有りのジョブは例外を投げるように修正する。

console.log('Loading function');
const AWS = require('aws-sdk');
exports.lambda_handler = (event, context, callback) => {
    console.log('event ' + JSON.stringify(event));
    console.log('context ' + JSON.stringify(context));

    const taskToken = event.TaskToken;
    const message = event.Message;

    const params = {
        taskToken: taskToken,
        output: "\"" + message + "\""
    }

    const stepfunctions = new AWS.StepFunctions();
    stepfunctions.sendTaskSuccess(params, function(err, data) {
        {
            console.log("Error", data);
            callback(null, "Error");
        }
    });
    throw new Error("Unknown Error")
}

エラーになった。

親側はタイムアウトで認識される。

ここでLambdaのソースコードを元に戻して子のステートマシンを再実行する。

正常終了するが 親側は再開しない。 ネストの場合は親のステートマシンからの再処理が必要になるようだ。

quo1987 4ヶ月前に更新

親ステートマシンの待機中に子のステートマシンをRedriveする

以前の結果を受けて、親側のタイムアウトを十分大きくして待機中に子のステートマシンをRedriveしてみる。

 "States": {
            "Start new workflow and wait for callback": {
              "Comment": "Start an execution and wait for it to call back with a task token",
              "Type": "Task",
              "Resource": "arn:aws:states:::states:startExecution.waitForTaskToken",
              "Parameters": {
                "StateMachineArn": "arn:aws:states:ap-northeast-1:188970983837:stateMachine:NestingPatternAnotherStateMachine-jnTiEDCysncq",
                "Input": {
                  "NeedCallback": true,
                  "AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID.$": "$$.Execution.Id",
                  "TaskToken.$": "$$.Task.Token"
                }
              },
              "End": true,
              "TimeoutSeconds": 999999
            }

子のステートマシンがエラーになり、親のステートマシンは待機中。