Skip to content

feat: Add Cloudflare Workflows integration for Agents #27893

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
agents-git-bot wants to merge 1 commit into
base: production
Choose a base branch
from
+85 −0
Open

feat: Add Cloudflare Workflows integration for Agents #27893

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
85 changes: 85 additions & 0 deletions src/content/changelog/agents/2026-01-28-agents-workflows-integration.mdx
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,85 @@
---
title: Kick off long-running Workflows from your Agents
description: The Agents SDK now has first-class support for Cloudflare Workflows, enabling durable multi-step background processing with automatic tracking and bidirectional communication.
products:
- agents
- workflows
date: 2026-01-28
---

import { TypeScriptExample } from "~/components";

The Agents SDK now has first-class support for [Cloudflare Workflows](/workflows/), allowing you to kick off durable, long-running async tasks from your Agent. Track workflow progress, sync state back to your Agent, and implement human-in-the-loop approval flows—all with automatic tracking in SQLite.

Use the new `AgentWorkflow` class to define workflows with typed access to your Agent:

<TypeScriptExample>

```ts
import { AgentWorkflow } from "agents";
import type { AgentWorkflowEvent, AgentWorkflowStep } from "agents";

export class ProcessingWorkflow extends AgentWorkflow<MyAgent, TaskParams> {
async run(event: AgentWorkflowEvent<TaskParams>, step: AgentWorkflowStep) {
// Report progress to Agent
await this.reportProgress({ step: "process", percent: 0.5 });

// Call Agent methods via RPC
await this.agent.updateStatus(event.payload.taskId, "processing");

const result = await step.do("process", async () => {
return processData(event.payload.data);
});

await step.reportComplete(result);
return result;
}
}
```

</TypeScriptExample>

Start workflows from your Agent with `runWorkflow()` and handle lifecycle events:

<TypeScriptExample>

```ts
export class MyAgent extends Agent {
async startTask(taskId: string, data: string) {
// Automatically tracked in Agent database
const workflowId = await this.runWorkflow("PROCESSING_WORKFLOW", {
taskId,
data,
});
return { workflowId };
}

async onWorkflowProgress(
workflowName: string,
workflowId: string,
progress: unknown,
) {
this.broadcast(JSON.stringify({ type: "progress", progress }));
}

async onWorkflowComplete(
workflowName: string,
workflowId: string,
result?: unknown,
) {
console.log(`Workflow ${workflowId} completed`);
}
}
```

</TypeScriptExample>

Key capabilities:

- **Automatic tracking** in the Agent SQLite database
- **Progress reporting** with typed progress objects
- **Bidirectional communication** between Agents and Workflows via RPC
- **State synchronization** from Workflows back to Agents (broadcasts to clients)
- **Human-in-the-loop** with `waitForApproval()` and `approveWorkflow()`/`rejectWorkflow()`

For the complete API reference and patterns, see [Integrate with Cloudflare Workflows](/agents/guides/workflows-integration/).
Loading