Skills agents-sdk

Build AI agents on Cloudflare Workers using the Agents SDK. Load when creating stateful agents, durable workflows, real-time WebSocket apps, scheduled tasks, MCP servers, chat applications, voice agents, or browser automation. Covers Agent class, state management, callable RPC, Workflows, durable execution, queues, retries, observability, and React hooks. Biases towards retrieval from Cloudflare docs over pre-trained knowledge.

install
source · Clone the upstream repo
git clone https://github.com/cloudflare/skills
Claude Code · Install into ~/.claude/skills/
T=$(mktemp -d) && git clone --depth=1 https://github.com/cloudflare/skills "$T" && mkdir -p ~/.claude/skills && cp -r "$T/skills/agents-sdk" ~/.claude/skills/cloudflare-skills-agents-sdk && rm -rf "$T"
manifest: skills/agents-sdk/SKILL.md
source content

Cloudflare Agents SDK

Your knowledge of the Agents SDK may be outdated. Prefer retrieval over pre-training for any Agents SDK task.

Retrieval Sources

Cloudflare docs: https://developers.cloudflare.com/agents/

TopicDocs URLUse for
Getting startedQuick startFirst agent, project setup
Adding to existing projectAdd to existing projectInstall into existing Workers app
ConfigurationConfiguration
wrangler.jsonc
, bindings, assets, deployment
Agent classAgents APIAgent lifecycle, patterns, pitfalls
StateStore and sync state
setState
,
validateStateChange
, persistence
RoutingRoutingURL patterns,
routeAgentRequest
Callable methodsCallable methods
@callable
, RPC, streaming, timeouts
SchedulingSchedule tasks
schedule()
,
scheduleEvery()
, cron
WorkflowsRun workflows
AgentWorkflow
, durable multi-step tasks
HTTP/WebSocketsWebSocketsLifecycle hooks, hibernation
Chat agentsChat agents
AIChatAgent
, streaming, tools, persistence
Client SDKClient SDK
useAgent
,
useAgentChat
, React hooks
Client toolsClient toolsClient-side tools,
autoContinueAfterToolResult
Server-driven messagesTrigger patterns
saveMessages
,
waitUntilStable
, server-initiated turns
Resumable streamingResumable streamingStream recovery on disconnect
EmailEmailEmail routing, secure reply resolver
MCP clientMCP clientConnecting to MCP servers
MCP serverMCP serverBuilding MCP servers with
McpAgent
MCP transportsMCP transportsStreamable HTTP, SSE, RPC transport options
Securing MCP serversSecuring MCPOAuth, proxy MCP, hardening
Human-in-the-loopHuman-in-the-loopApproval flows,
needsApproval
, workflows
Durable executionDurable execution
runFiber()
,
stash()
, surviving DO eviction
QueueQueueBuilt-in FIFO queue,
queue()
RetriesRetries
this.retry()
, backoff/jitter
ObservabilityObservabilityDiagnostics-channel events
Push notificationsPush notificationsWeb Push + VAPID from agents
WebhooksWebhooksReceiving external webhooks
Cross-domain authCross-domain authWebSocket auth, tokens, CORS
Readonly connectionsReadonly
shouldConnectionBeReadonly
VoiceVoiceExperimental STT/TTS,
withVoice
Browse the webBrowser toolsExperimental CDP browser automation
ThinkThinkExperimental higher-level chat agent class
MigrationsAI SDK v5, AI SDK v6Upgrading
@cloudflare/ai-chat

Capabilities

The Agents SDK provides:

  • Persistent state — SQLite-backed, auto-synced to clients via
    setState
  • Callable RPC
    @callable()
    methods invoked over WebSocket
  • Scheduling — One-time, recurring (
    scheduleEvery
    ), and cron tasks
  • Workflows — Durable multi-step background processing via
    AgentWorkflow
  • Durable execution
    runFiber()
    /
    stash()
    for work that survives DO eviction
  • Queue — Built-in FIFO queue with retries via
    queue()
  • Retries
    this.retry()
    with exponential backoff and jitter
  • MCP integration — Connect to MCP servers or build your own with
    McpAgent
  • Email handling — Receive and reply to emails with secure routing
  • Streaming chat
    AIChatAgent
    with resumable streams, message persistence, tools
  • Server-driven messages
    saveMessages
    ,
    waitUntilStable
    for proactive agent turns
  • React hooks
    useAgent
    ,
    useAgentChat
    for client apps
  • Observability
    diagnostics_channel
    events for state, RPC, schedule, lifecycle
  • Push notifications — Web Push + VAPID delivery from agents
  • Webhooks — Receive and verify external webhooks
  • Voice (experimental) — STT/TTS via
    @cloudflare/voice
  • Browser tools (experimental) — CDP-powered browsing via
    agents/browser
  • Think (experimental) — Higher-level chat agent via
    @cloudflare/think

FIRST: Verify Installation

npm ls agents  # Should show agents package

If not installed:

npm install agents

For chat agents:

npm install agents @cloudflare/ai-chat ai @ai-sdk/react

Wrangler Configuration

{
  "compatibility_flags": ["nodejs_compat"],
  "durable_objects": {
    "bindings": [{ "name": "MyAgent", "class_name": "MyAgent" }]
  },
  "migrations": [{ "tag": "v1", "new_sqlite_classes": ["MyAgent"] }]
}

Gotchas:

  • Do NOT enable
    experimentalDecorators
    in tsconfig (breaks
    @callable
    )
  • Never edit old migrations — always add new tags
  • Each agent class needs its own DO binding + migration entry
  • Add
    "ai": { "binding": "AI" }
    for Workers AI

Agent Class

import { Agent, routeAgentRequest, callable } from "agents";

type State = { count: number };

export class Counter extends Agent<Env, State> {
  initialState = { count: 0 };

  validateStateChange(nextState: State, source: Connection | "server") {
    if (nextState.count < 0) throw new Error("Count cannot be negative");
  }

  onStateUpdate(state: State, source: Connection | "server") {
    console.log("State updated:", state);
  }

  @callable()
  increment() {
    this.setState({ count: this.state.count + 1 });
    return this.state.count;
  }
}

export default {
  fetch: (req, env) => routeAgentRequest(req, env) ?? new Response("Not found", { status: 404 })
};

Routing

Requests route to

/agents/{agent-name}/{instance-name}
:

ClassURL
Counter
/agents/counter/user-123
ChatRoom
/agents/chat-room/lobby

Client:

useAgent({ agent: "Counter", name: "user-123" })

Custom routing: use

getAgentByName(env.MyAgent, "instance-id")
then
agent.fetch(request)
.

Core APIs

TaskAPI
Read state
this.state.count
Write state
this.setState({ count: 1 })
SQL query
this.sql`SELECT * FROM users WHERE id = ${id}`
Schedule (delay)
await this.schedule(60, "task", payload)
Schedule (cron)
await this.schedule("0 * * * *", "task", payload)
Schedule (interval)
await this.scheduleEvery(30, "poll")
RPC method
@callable() myMethod() { ... }
Streaming RPC
@callable({ streaming: true }) stream(res) { ... }
Start workflow
await this.runWorkflow("ProcessingWorkflow", params)
Durable fiber
await this.runFiber("name", async (ctx) => { ... })
Enqueue work
this.queue("handler", payload)
Retry with backoff
await this.retry(fn, { maxAttempts: 5 })
Broadcast to clients
this.broadcast(message)
Get connections
this.getConnections(tag?)

React Client

import { useAgent } from "agents/react";

function App() {
  const [state, setLocalState] = useState({ count: 0 });

  const agent = useAgent({
    agent: "Counter",
    name: "my-instance",
    onStateUpdate: (newState) => setLocalState(newState),
    onIdentity: (name, agentType) => console.log(`Connected to ${name}`)
  });

  return (
    <button onClick={() => agent.setState({ count: state.count + 1 })}>
      Count: {state.count}
    </button>
  );
}

References

Core

Chat & Streaming

Background Processing

Integrations

Experimental