Steps

const data = await step("fetch-data", async () => {
  return await fetchDataFromAPI();
});

await step.listen("wait-for-approval");
// Workflow pauses here until triggered

// Sleep for 5 minutes
await step.sleep("wait-5-min", 5 * 60 * 1000);

await step.sleepUntil("wait-until-noon", new Date("2025-01-15T12:00:00Z"));

if (!user.isVerified) {
  await step.fail("User verification required");
}

if (shouldPause) {
  step.abort();
}

await step.progress("Started processing");
// ... do work ...
await step.progress("Finished processing");

const childWorkflow = await childWorkflowInstance.start({});
const result = await step.waitForWorkflow("wait-for-child", childWorkflow.id);

import ProcessingWorkflow from "../workflows/processing";

const result = await step.executeWorkflow(
  "process-data",
  ProcessingWorkflow,
  { data: inputData }
);

const results = await step.map(
  "process-users",
  users,
  async (user, { i }) => await processUser(user),
  { concurrency: 5, maxAttempts: 3 }
);

await step.forEach(
  "notify-users",
  users,
  async (user) => await sendNotification(user),
  { concurrency: 10 }
);

await step.batch(
  "bulk-insert",
  records,
  async (batch) => await database.bulkInsert(batch),
  { batchSize: 100 }
);

export default new Workflow({
  name: "order-workflow",
  requests: {
    orderId: z.object({
      orderId: z.string(),
    }),
  },
  handler: async ({ step }) => {
    const data = await step.request("orderId", "Please provide the order ID");
    // data is typed based on the request schema
  },
});