import { WorkflowEntrypoint } from "cloudflare:workers";

export class DataProcessingWorkflow extends WorkflowEntrypoint {
  async run(event, step) {
    // This step will be automatically retried on failure
    const result = await step.do("processData", async () => {
      const input = event.payload.data;
      return input;
    });

    // Another step that can be retried independently
    await step.do("transform", async () => {
      return result.map((item) => ({ ...item, processed: true }));
    });
  }
}