Function createStore

src/node/services/workflows/WorkflowRunStore.test.ts:18–29

(sessionDir: string, staleLeaseMs = 10)

const source = "export default async function workflow() { return 'ok'; }\n";

async function createStore(sessionDir: string, staleLeaseMs = 10) {
  const store = new WorkflowRunStore({ sessionDir, staleLeaseMs });
  await store.createRun({
    id: "wfr_123",
    workspaceId: "workspace-1",
    workflow: definition,
    source: source,
    args: { topic: "durable runs" },
    now: "2026-05-29T00:00:00.000Z",
  });
  return store;
}

describe("WorkflowRunStore", () => {
  test("persists captured workflow source and reloads run state", async () => {