(sessionDir: string)
| 32 | `; |
| 33 | |
| 34 | async function createRunStore(sessionDir: string) { |
| 35 | const store = new WorkflowRunStore({ |
| 36 | sessionDir, |
| 37 | staleLeaseMs: WORKFLOW_RUNNER_TEST_STALE_LEASE_MS, |
| 38 | }); |
| 39 | await store.createRun({ |
| 40 | id: "wfr_123", |
| 41 | workspaceId: "workspace-1", |
| 42 | workflow: definition, |
| 43 | source: source, |
| 44 | args: { topic: "durable workflows" }, |
| 45 | now: "2026-05-29T00:00:00.000Z", |
| 46 | }); |
| 47 | return store; |
| 48 | } |
| 49 | |
| 50 | function createRunner(store: WorkflowRunStore, taskAdapter: WorkflowTaskAdapter) { |
| 51 | return new WorkflowRunner({ |
no test coverage detected