Class RecoveryExtensions

Namespace

WorkflowForge.Extensions.Persistence.Recovery

Assembly

WorkflowForge.Extensions.Persistence.Recovery.dll

Extensions that provide recovery orchestration on top of persistence. Attempts to resume from a snapshot first, then runs a fresh execution with configurable retries.

public static class RecoveryExtensions

Inheritance

object

RecoveryExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

ForgeWithRecoveryAsync(IWorkflowSmith, IWorkflow, IWorkflowFoundry, IWorkflowPersistenceProvider, Guid, Guid, RecoveryMiddlewareOptions?, CancellationToken)

Attempts to resume a workflow from the last checkpoint before starting a new execution with options. If no snapshot exists, proceeds to execute normally.

public static Task ForgeWithRecoveryAsync(this IWorkflowSmith smith, IWorkflow workflow, IWorkflowFoundry foundry, IWorkflowPersistenceProvider provider, Guid foundryKey, Guid workflowKey, RecoveryMiddlewareOptions? options = null, CancellationToken cancellationToken = default)

Parameters

smith IWorkflowSmith

workflow IWorkflow

foundry IWorkflowFoundry

provider IWorkflowPersistenceProvider

foundryKey Guid

workflowKey Guid

options RecoveryMiddlewareOptions

cancellationToken CancellationToken

Returns

Task