公開日: 2026-05-01

Workflows、Workers — @cloudflare/dynamic-workflows ライブラリで Dynamic Workers 内で Workflows を実行する

@cloudflare/dynamic-workflows ↗ を使って、ランタイムでロードされるコードに対しても耐久性のある実行を保証しつつ、Dynamic Worker の内部で Workflow を実行できるようになりました。

Worker Loader は Dynamic Worker をオンデマンドでロードするため、これまでは耐久性の確保が困難でした。Dynamic Worker 内の Workflow はステップ間で数時間または数日間スリープする可能性があり、再開時には元の Dynamic Worker コードがメモリ上に存在しないことがあります。

このライブラリは、各 Workflow インスタンスにどの Dynamic Worker をロードするかを識別するメタデータ（例えば tenant ID）をタグ付けし、Workflow が再開するたびに Worker Loader を通して該当する Dynamic Worker を再ロードすることでこの問題を解決します。Dynamic Workers はオンデマンドで作成されるため、各 Workflow を事前に登録したり個別に管理したりする必要はありません。必要なときに Dynamic Worker 内で Workflow コードをロードし、Workflows エンジンが永続化やリトライを裏側で処理します。Workflow コード自体にルーティングのための変更は不要で、通常どおり動作します。

これにより、Workflow コード自体が動的であるパターンが可能になります。例えば次のようなユースケースで有用です:

• SaaS プラットフォーム: 各テナントがオンボーディングシーケンス、承認チェーン、課金のリトライロジックなど独自のオートメーションを定義するケース。
• AI エージェントフレームワーク: エージェントが実行時にマルチステップの計画を生成・実行し、ツール呼び出しの間に人間の承認を待つなど、再起動や待機をまたいで継続するケース。
• マルチテナントのジョブシステム: 各顧客が独自の処理ロジックを提出し、各ステップが進捗を永続化して失敗時にリトライするケース。

使用例 (TypeScript)

以下は @cloudflare/dynamic-workflows を使って、テナントごとにコードをロードして Workflow を実行する例です。

import { createDynamicWorkflowEntrypoint, DynamicWorkflowBinding, wrapWorkflowBinding, type WorkflowRunner, } from "@cloudflare/dynamic-workflows";
export { DynamicWorkflowBinding };
interface Env { WORKFLOWS: Workflow; LOADER: WorkerLoader; }
function loadTenant(env: Env, tenantId: string) {
    return env.LOADER.get(tenantId, async () => ({
        compatibilityDate: "2026-01-01",
        mainModule: "index.js",
        modules: { "index.js": await fetchTenantCode(tenantId) },
        // The Dynamic Worker uses this exactly like a real Workflow binding;
        // every create() is tagged with { tenantId } automatically.
        env: { WORKFLOWS: wrapWorkflowBinding({ tenantId }) },
    }));
}
// The entrypoint name must match `class_name` in the workflows binding of your Wrangler config file.
export const DynamicWorkflow = createDynamicWorkflowEntrypoint<Env>(
    async ({ env, metadata }) => {
        const stub = loadTenant(env, metadata.tenantId as string);
        return stub.getEntrypoint("TenantWorkflow") as unknown as WorkflowRunner;
    },
);
export default {
    fetch(request: Request, env: Env) {
        const tenantId = request.headers.get("x-tenant-id")!;
        return loadTenant(env, tenantId).getEntrypoint().fetch(request);
    },
};

注: 上記の例では、Dynamic Worker の構成で Workflows バインディングの class_name とエントリポイント名が一致する必要があります。

詳細とリソース

詳細なウォークスルーについては Dynamic Workflows guide を参照してください。