Aller au contenu
English

recoverSpeculation

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

Libère la propriété d’une course durable dont le coordinateur s’est arrêté, à condition que son objet enregistré soit toujours à la révision indiquée ; sinon rejette avec TransportConflict. N’arrête et ne supprime rien : le prochain appel à speculate() arrête les ressources enregistrées et exige resume: retry-incomplete pour rejouer les candidats interrompus.

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

  • optionsRequis
    SpeculationRecoveryOptions
    Identité de la course abandonnée, révision inspectée et confirmation explicite de l’arrêt de son coordinateur.
  • options.runIdRequis
    string
    runId de la course à libérer.
  • options.revisionRequis
    string
    Révision de l’objet enregistré telle que vous l’avez lue ; si elle a changé depuis, la récupération rejette avec TransportConflict.
  • options.coordinatorStoppedRequis
    true
    Confirmation explicite de l’arrêt de l’ancien coordinateur ; un PID distant ou un délai écoulé ne constitue pas une preuve.
  • 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.

Promise<void>

export declare function recoverSpeculation(
  options: SpeculationRecoveryOptions,
): Promise<void>;