Aller au contenu
English

WorkflowCheckpointStore

import type { WorkflowCheckpointStore } from "@elie-laloum/outpost";
  • acquireRequis
    (runId: string) => Promise<WorkflowCheckpointLease>
    Prend la possession exclusive de runId et renvoie son bail. createWorkflowCheckpointStore() rejette tant qu’un propriétaire est enregistré, y compris celui d’un processus mort, jusqu’à ce que recoverWorkflowCheckpoint() l’efface.
export interface WorkflowCheckpointStore {
  acquire(runId: string): Promise<WorkflowCheckpointLease>;
}