createWorkflowCheckpointStore

Rôle et comportement

Crée un WorkflowCheckpointStore qui conserve le checkpoint et le propriétaire de chaque exécution dans un seul objet, checkpoints/<SHA-256 du runId>.json. acquire() échoue tant qu’un propriétaire est enregistré, et la libération conserve la progression. La propriété n’expire jamais : après un crash, arrêtez l’ancien exécuteur et appelez recoverWorkflowCheckpoint().

Exemple complet et règles détaillées.

Paramètres et propriétés

• optionsRequis
  TransportStoreOptions
  Transport qui contient un objet par exécution sous checkpoints/, avec son checkpoint et son propriétaire.
• options.transporterRequis
  Transport
  Transport objet appartenant à l’appelant, utilisé par le store ou l’opération. Fermer un workflow ou une sandbox ne ferme pas ce transport.

Retour

WorkflowCheckpointStore

Signature

export declare function createWorkflowCheckpointStore(
  options: TransportStoreOptions,
): WorkflowCheckpointStore;

Contrats associés

• TransportStoreOptions
• WorkflowCheckpointStore