Canceling Workflows

import { ow } from "./openworkflow/client";
import { defineWorkflow } from "openworkflow";

const longRunning = defineWorkflow(
  { name: "long-running" },
  async ({ step }) => {
    await step.sleep("wait", "1 hour");
    await step.run({ name: "work" }, () => doExpensiveWork());
  },
);

// Start the workflow
const handle = await ow.runWorkflow(longRunning.spec);

// Cancel it before it completes
await handle.cancel();

try {
  await handle.cancel();
} catch (error) {
  // "Cannot cancel workflow run abc123 with status completed"
}

const handle = await ow.runWorkflow(workflow.spec);
await handle.cancel();

// Waiting for result on a canceled workflow throws
try {
  await handle.result();
} catch (error) {
  // "Workflow my-workflow was canceled"
}

await handle.cancel(); // Cancels the workflow
await handle.cancel(); // No error - already canceled