WorkflowCheckpointStore

import type { WorkflowCheckpointStore } from "@elie-laloum/outpost";

Parameters and properties

acquireRequired
(runId: string) => Promise<WorkflowCheckpointLease>
Takes exclusive ownership of runId and returns its lease. createWorkflowCheckpointStore() rejects while an owner is recorded, including one left by a dead process, until recoverWorkflowCheckpoint() clears it.

Signature

export interface WorkflowCheckpointStore {
  acquire(runId: string): Promise<WorkflowCheckpointLease>;
}

WorkflowCheckpointLease