Rollback support now available in Workflows

公開日: 2026-06-05

概要

Workflowsはsagaスタイルのロールバックをサポートするようになりました。各 step.do() に対して補償ロジック（rollbackハンドラ）を追加でき、下流の処理が失敗した場合に自動的に補償処理が実行されます。インスタンスが失敗した場合、ロールバックハンドラはステップの開始順序の逆順で実行されます。

利点とユースケース

• 複数ステップで外部システムに触れる操作（inventory reservations、payment authorization、ticket creation、infrastructure provisioning など）に有用。
• トップレベルの catch にすべてのクリーンアップ処理を書く代わりに、各ステップのそばにそのステップを取り消す補償アクションを置ける。
• ロールバックハンドラは独自の retry/timeout 設定をサポート。
• Workflows はインスタンスステータス応答でロールバックの結果を公開。
• Workflows analytics はロールバックのライフサイクルイベントも送出するため、本番ワークフローのデバッグ時に前進実行の失敗とロールバックの失敗を区別しやすくなる。

動作のポイント

• ロールバックは各ステップ単位で定義。
• ロールバックはステップの出力（output）にアクセス可能で、必要に応じてその出力を使って補償処理を行う。
• rollbackConfig でリトライやタイムアウトの挙動を設定可能。
• ロールバック結果はインスタンスのステータスに反映され、analytics イベントとしても記録される。

使用例（JavaScript）

await step.do(
  "provision resource",
  async () => {
    const resource = await provisionResource();
    return { resourceId: resource.id };
  },
  {
    rollback: async ({ output }) => {
      const { resourceId } = output;
      await deleteResource(resourceId);
    },
    rollbackConfig: {
      retries: { limit: 3, delay: "15 seconds", backoff: "linear" },
      timeout: "2 minutes",
    },
  },
);

使用例（TypeScript）

await step.do(
  "provision resource",
  async () => {
    const resource = await provisionResource();
    return { resourceId: resource.id };
  },
  {
    rollback: async ({ output }) => {
      const { resourceId } = output as { resourceId: string };
      await deleteResource(resourceId);
    },
    rollbackConfig: {
      retries: { limit: 3, delay: "15 seconds", backoff: "linear" },
      timeout: "2 minutes",
    },
  },
);

参照

Refer to rollback options to learn more.