§21 工作流与人工审批：可恢复的多步管线

import { AgentWorkflow } from "agents/workflows";

export class ProcessingWorkflow extends AgentWorkflow<MyAgent, TaskParams> {
  async run(event: AgentWorkflowEvent<TaskParams>, step: AgentWorkflowStep) {
    const params = event.payload;
    const result = await step.do("process-data", async () => processData(params.data)); // 持久+重试
    await this.reportProgress({ step: "process", status: "complete", percent: 0.5 });
    await step.do("save-results", async () => this.agent.saveResult(params.taskId, result));
    await step.reportComplete(result);
    return result;
  }
}

// Agent 内
const instanceId = await this.runWorkflow("PROCESSING_WORKFLOW", { taskId, data });

// wrangler 注册 workflow
"workflows": [{ "name": "processing-workflow", "binding": "PROCESSING_WORKFLOW", "class_name": "ProcessingWorkflow" }]

const approvalData = await this.waitForApproval<{ approvedBy: string }>(step, { timeout: "7 days" });
// Agent 端：this.approveWorkflow(id, {...}) / this.rejectWorkflow(id, {...})