Cloudflare Workflows：Durable Execution AIエージェント

自律型AIエージェント（Autonomous AI Agents）が主流となった2026年、エンタープライズ環境でAIエージェントを本番環境（プロダクション）に導入する際に直面する最大の障害は、短時間のサーバーレスタイムアウト（HTTP 30秒/5分制約）と外部API呼び出し失敗時のワークフロー全体復旧不可現象です。LLM推論、ウェブブラウジング、コード実行、ヒューマン・イン・ザ・ループ（Human-in-the-loop）の承認プロセスが数分から数時間に及ぶ際、従来の非永続的（Ephemeral）なLambda/Worker関数では途中でメモリが消失したり、再試行時に最初のステップから無駄に再実行されてしまいます。

この問題を根本的に解決するために発表された技術が、Cloudflare Workflowsの**Durable Execution（耐久実行）**パイプラインです。

この記事では、Cloudflareの最新エッジオーケストレーションエンジンであるCloudflare Workflowsを活用し、ネットワーク障害やエージェントの中断が発生しても各ステップの状態を自動チェックポインティング（Checkpointing）し、50,000件の同時実行性を保証しながら、Cloudflare Agents SDKガイドおよびDeepSeek-R1 MLXガイドと連携するエンタープライズマルチエージェントワークフローを完璧に構築します。

要約

• Durable Execution（耐久実行）: エージェントワークフローのすべての step.do() 実行結果が自動チェックポインティングされ、サーバーダウンやAPI失敗時にも直前の成功地点から即座に復元（Hydrate）されます。
• サーバーレスタイムアウトの完全解消: 単一HTTPリクエストのタイムアウト制約から解放され、数日・数週間にわたって待機する長期実行（Long-running）AIエージェントタスクが可能になります。
• Human-in-the-loop & 承認待機: step.sleep() および外部イベント待機を通じて、人間の承認が得られるまでコンピューティングコスト0円で待機モードを維持します。
• 圧倒的な拡張性: 1秒あたり300個のインスタンス生成および50,000個の同時実行（Concurrent Instances）をサポートし、AWS Step Functionsと比較してコストを80%以上削減します。

1. 非永続的エージェント vs Durable Executionアーキテクチャ

従来の関数型エージェントとCloudflare Workflowsの決定的な違いです。

[従来の非永続的エージェントアーキテクチャ] ❌
[Step 1: LLM企画] ──► [Step 2: Webクローリング] ──► [Step 3: コード実行中にタイムアウト/エラー!]
                                                          ▼
                                            プロセス全体が消失 & Step 1から再実行（コスト/時間の無駄）

[Cloudflare Workflows Durable Execution] ⭕️
[Step 1: LLM企画] (Checkpointing)
         ▼
[Step 2: Webクローリング] (Checkpointing)
         ▼
[Step 3: コード実行中に障害発生] ──► 自動復元(Hydrate) ──► Step 3のみ再試行および完了!

2. Cloudflare Workflowsオーケストレーション4大要素

Cloudflare Workflows公式開発ドキュメントの仕様に基づくコアプリミティブ構成です。

1. WorkflowEntry: ワークフロー全体の流入口（エントリポイント）クラス（Workflow クラスを継承）。
2. step.do(): 単一トランザクション単位のステップ。成功時に結果が永久保存され、該当ステップの再実行がバイパスされます。
3. step.sleep(): コンピューティングリソースを返却したまま一定時間停止する待機ステップ（コスト $0）。
4. step.sleepUntil(): 指定した未来の時刻やイベント（Human Approval）受信時点までアイドル状態で待機。

3. 実戦実装コード：自律型研究 & レポート生成エージェント

Webリサーチ ➔ 分析 ➔ 人間の承認 ➔ 最終レポート送信へとつながる Durable AI Agent Workflow の TypeScript 実装コード全体です。

import { WorkflowEntrypoint, WorkflowEvent, WorkflowStep } from 'cloudflare:workers';

interface Env {
  AI: any;
  MY_WORKFLOW: Workflow;
}

interface AgentParams {
  topic: string;
  requesterEmail: string;
}

export class ResearchAgentWorkflow extends WorkflowEntrypoint<Env, AgentParams> {
  async run(event: WorkflowEvent<AgentParams>, step: WorkflowStep) {
    const { topic, requesterEmail } = event.payload;

    // Step 1: LLMベースのサブリサーチ計画策定 (チェックポイント 1)
    const researchPlan = await step.do('generate-research-plan', async () => {
      const response = await this.env.AI.run('@cf/meta/llama-3.3-70b-instruct', {
        messages: [
          { role: 'system', content: 'あなたは主任研究員AIです。調査するサブトピック3つを抽出してください。' },
          { role: 'user', content: `トピック: ${topic}` },
        ],
      });
      return response.response;
    });

    // Step 2: 外部APIクローリングおよびデータ収集 (チェックポイント 2)
    // この段階で外部APIタイムアウトが発生してもStep 1を再実行しない
    const collectedData = await step.do('crawl-web-sources', async () => {
      const searchResults = await fetch(`https://api.search-provider.com/v1/search?q=${encodeURIComponent(topic)}`);
      return await searchResults.json();
    });

    // Step 3: AI総合レポート1次ドラフト作成 (チェックポイント 3)
    const draftReport = await step.do('synthesize-report-draft', async () => {
      const summary = await this.env.AI.run('@cf/meta/llama-3.3-70b-instruct', {
        messages: [
          { role: 'system', content: `収集された資料を統合して3,000字の技術レポートを作成してください。` },
          { role: 'user', content: `計画: ${researchPlan}\n資料: ${JSON.stringify(collectedData)}` },
        ],
      });
      return summary.response;
    });

    // Step 4: 人間のレビューおよび承認のため24時間アイドル待機 (コスト0円)
    // この待機時間中にサーバーメモリを占有しない
    await step.sleep('wait-for-human-approval', '24 hours');

    // Step 5: 最終レポートメール送信 (チェックポイント 4)
    await step.do('send-final-email', async () => {
      await fetch('https://api.email-service.com/v1/send', {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({
          to: requesterEmail,
          subject: `[完了] ${topic} AI総合リサーチレポート`,
          body: draftReport,
        }),
      });
    });

    return { status: 'completed', topic, timestamp: new Date().toISOString() };
  }
}

export default {
  async fetch(request: Request, env: Env): Promise<Response> {
    const url = new URL(request.url);
    if (url.pathname === '/start-agent') {
      const { topic, email } = await request.json<{ topic: string; email: string }>();

      // Durable Workflow インスタンス生成および実行トリガー
      const instance = await env.MY_WORKFLOW.create({
        params: { topic, requesterEmail: email },
      });

      return Response.json({ instanceId: instance.id, status: 'started' });
    }
    return new Response('Not Found', { status: 404 });
  },
};

4. パフォーマンスおよびコストベンチマーク：Cloudflare Workflows vs AWS Step Functions

月100万件の長期実行AIエージェントワークフロー処理時におけるベンチマーク結果です。

AWS LambdaからCloudflare Workersへのエグレス削減マイグレーションガイドおよびCloudflare AI Gatewayコスト制御ガイドと連携することで、インフラ全体の運用コストを80%以上画期的に削減できます。

5. Dynamic Workflows：マルチテナントAIエージェントの動的隔離

2026年にアップデートされたDynamic Workflowsを適用すると、SaaSプラットフォームにおいて顧客（Tenant）ごとに異なるLLMプロンプトルールやエージェントパイプラインコードを安全に注入できます。

// テナント別動的エージェントワークフローインスタンス生成例
const tenantWorkflow = await env.DYNAMIC_WORKFLOWS.get(tenantId);
const instance = await tenantWorkflow.create({
  params: { customPrompt: tenantConfig.prompt, payload },
});

このパターンにより、マルチテナント環境においても各テナントのエージェント実行状態が完全に隔離（Isolated）され、個別エージェントの誤作動がシステム全体に影響を与えることはありません。

6. エンタープライズ導入時のベストプラクティス・チェックリスト

よくある質問

step.do() 内部でエラーが発生した場合、ワークフロー全体が停止しますか？

デフォルトでは該当するステップのみリトライ（Retry）を実行します。指定した最大リトライ回数を超過した場合は、try-catch ブロックを通じて代替（Fallback）ステップへ迂回するか、ワークフロー失敗状態へと安全に移行できます。

待機（Sleep）状態の際、本当にサーバー費用がまったく請求されないのですか？

はい、100%無料です。step.sleep() が実行されると、該当のワークフローインスタンスはエッジサーバーのメモリから完全に退避され（Dehydrate）、指定した時刻になった際のみエッジエンジンが状態を復元（Hydrate）して次のステップを継続実行します。

Cloudflare Agents SDKとCloudflare Workflowsはどのように併用しますか？

ユーザーとのリアルタイムなWebSocket会話および短期メモリ管理は Agents SDK(Durable Objects) が担当し、リサーチや外部APIバッチ処理、決済承認などの長期実行プロセスは Workflows に委任する双方向ハイブリッドアーキテクチャが2026年のベストプラクティスです。

従来のTemporalやAWS Step Functionsのコードからの移行は簡単ですか？

概念的な構造（Step, Sleep, Retry）が同一であるため、非常に簡単です。従来のJSON定義や複雑なYAMLファイルの代わりに、使い慣れたTypeScriptコードの直感性をそのまま利用できるため、開発者の生産性が2倍以上向上します。