Interface WorkflowRunnerPersistence

Optional persistence hooks for workflow execution snapshots.

interface WorkflowRunnerPersistence {
    loadWorkflowExecution?: (
        workflowId: string,
    ) =>
        | WorkflowExecutionSnapshot<any>
        | Promise<WorkflowExecutionSnapshot<any> | undefined>
        | undefined;
    persistWorkflowExecution?: (
        snapshot: WorkflowExecutionSnapshot<any>,
    ) => void | Promise<void>;
}

Properties

loadWorkflowExecution?: (
    workflowId: string,
) =>
    | WorkflowExecutionSnapshot<any>
    | Promise<WorkflowExecutionSnapshot<any> | undefined>
    | undefined

Load the latest snapshot for a workflow id.

persistWorkflowExecution?: (
snapshot: WorkflowExecutionSnapshot<any>,
) => void | Promise<void>

Persist the current workflow snapshot (called incrementally during execution).