update

Author: mia303

src/content/docs/workflows/examples/dynamic-workflows.mdx

@@ -18,6 +18,8 @@ For example, an AI agent might decide at runtime to create a Workflow with these
 
 With Dynamic Workers and Workflows, the Worker Loader, which loads Dynamic Workers, can create that Workflow on the spot, run it durably, and let Workflows handle retries, sleeping, and waiting for events. You do not need to pre-register a separate Workflow class for every run.
 
+In this example, we'll set up a simple Dynamic Workflow which allows you to run arbitrary Workflows code at runtime.
+
 ## When to use this pattern
 
 Use this pattern when your workflow logic is not known at deploy time.
@@ -80,7 +82,7 @@ Your Worker needs two things:
 
 Although the Workflow is not statically defined, you still deploy one normal Workflow class. Its job is to load the dynamic code for the current run and call it with the `WorkflowStep` object. This class is what makes the [Workflows API](/workflows/build/workers-api/), including `step.do()`, `step.sleep()`, and `step.waitForEvent()`, continue to work as normal.
 
-Use `env.LOADER.get(id, callback)` via the [Worker Loader API](/dynamic-workers/api-reference/#load) to create the Dynamic Worker. If the Dynamic Worker has already been created, the Worker Loader uses its `workerId` to reload the code and use the same Dynamic Worker.
+Use `env.LOADER.get()` via the [Worker Loader API](/dynamic-workers/api-reference/#load) to create the Dynamic Worker. If the Dynamic Worker has already been created, the Worker Loader uses its `workerId` to reload the code and use the same Dynamic Worker.
 
 <TypeScriptExample>
 
@@ -119,58 +121,69 @@ export class DynamicWorkflow extends WorkflowEntrypoint<Env, Params> {
 }
 ```
 
-<TypeScriptExample>
-
-```ts
-function loadDynamicWorkflow(env: Env, scriptId: string, script: string) {
-	return env.LOADER.get(`dynamic-workflow:${scriptId}`, async () => ({
-		compatibilityDate: "$today",
-		mainModule: "index.js",
-		modules: {
-			"index.js": script,
-		},
-		globalOutbound: null,
-	}));
-}
-```
-
 </TypeScriptExample>
 
-## Write the dynamic workflow code
-
-The dynamic code defines the steps for one run. It is regular Worker code loaded at runtime.
-
-This example implements the support-ticket flow described earlier:
-
-1. Summarize the ticket
-2. Wait for approval
-3. Send a follow-up
+## Create your Worker entrypoint
 
 <TypeScriptExample>
 
 ```ts
-import { WorkerEntrypoint } from "cloudflare:workers";
-
-export class DynamicWorkflowLogic extends WorkerEntrypoint {
-	async run(event, step) {
-		const summary = await step.do("summarize ticket", async () => {
-			const ticket = event.payload.ticket;
-			return `Summary: ${ticket.subject}`;
-		});
-
-		await step.waitForEvent("wait for approval", {
-			type: "ticket-approved",
-			timeout: "24 hours",
-		});
-
-		return step.do("send follow-up", async () => {
-			return {
-				sent: true,
-				message: `Approved follow-up sent for: ${summary}`,
-			};
-		});
-	}
-}
+export { DynamicWorkflow } from "./workflow";
+
+export default {
+	async fetch(request, env, ctx): Promise<Response> {
+		const url = new URL(request.url);
+
+		if (url.pathname === "/api/run" && request.method === "POST") {
+			try {
+				const { script } = (await request.json()) as { script: string };
+
+				if (!script || typeof script !== "string") {
+					return Response.json(
+						{ error: "script is required" },
+						{ status: 400 },
+					);
+				}
+
+				const instance = await env.WORKFLOW.create({
+					params: { script },
+				});
+
+				return Response.json({
+					instanceId: instance.id,
+					status: await instance.status(),
+				});
+			} catch (error) {
+				return Response.json(
+					{ error: error instanceof Error ? error.message : String(error) },
+					{ status: 500 },
+				);
+			}
+		}
+
+		if (url.pathname === "/api/status") {
+			const instanceId = url.searchParams.get("instanceId");
+			if (!instanceId) {
+				return Response.json(
+					{ error: "instanceId query param is required" },
+					{ status: 400 },
+				);
+			}
+
+			try {
+				const instance = await env.WORKFLOW.get(instanceId);
+				return Response.json(await instance.status());
+			} catch (error) {
+				return Response.json(
+					{ error: error instanceof Error ? error.message : String(error) },
+					{ status: 500 },
+				);
+			}
+		}
+
+		return new Response("Not Found", { status: 404 });
+	},
+} satisfies ExportedHandler<Env>;
 ```
 
 </TypeScriptExample>