using WorkflowForge;
using WorkflowForge.Extensions.Persistence.Abstractions;
using WorkflowForge.Extensions.Persistence.Recovery;
// Your provider must be shared (DB/cache) used also by the runtime persistence middleware
IWorkflowPersistenceProvider provider = new SQLitePersistenceProvider("workflows.db");
var coordinator = new RecoveryCoordinator(provider, new RecoveryPolicy
{
MaxAttempts = 3,
BaseDelay = TimeSpan.FromSeconds(1),
UseExponentialBackoff = true
});
await coordinator.ResumeAsync(
foundryFactory: () => WorkflowForge.CreateFoundry("OrderService"),
workflowFactory: BuildProcessOrderWorkflow,
foundryKey: stableFoundryKey,
workflowKey: stableWorkflowKey);
Key Features
Resume from Checkpoint: Continue workflows from last saved state
Exponential Backoff: Configurable retry with backoff
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using WorkflowForge.Extensions.Persistence.Recovery;
services.AddRecoveryConfiguration(configuration);
var options = serviceProvider.GetRequiredService<IOptions<RecoveryMiddlewareOptions>>().Value;
// Resume from last checkpoint
await coordinator.ResumeAsync(
foundryFactory: () => WorkflowForge.CreateFoundry("OrderService"),
workflowFactory: BuildProcessOrderWorkflow,
foundryKey: stableFoundryKey,
workflowKey: stableWorkflowKey);
Batch Recovery
public class MyCatalog : IRecoveryCatalog
{
private readonly IWorkflowPersistenceProvider _provider;
public async Task<IReadOnlyList<WorkflowExecutionSnapshot>> ListPendingAsync(
CancellationToken cancellationToken = default)
{
// Query your storage for pending workflows
return await _database.QueryAsync("SELECT * FROM Workflows WHERE Status = 'Pending'");
}
}
var catalog = new MyCatalog(provider);
int resumedCount = await coordinator.ResumeAllAsync(
foundryFactory: () => WorkflowForge.CreateFoundry("BatchRecovery"),
workflowFactory: BuildWorkflow,
catalog: catalog);
Important Notes
Stable Keys
Critical: Use stable, deterministic keys for foundry and workflow:
// Good: Stable keys
var foundryKey = Guid.Parse("FIXED-GUID-FOR-ORDER-SERVICE");
var workflowKey = Guid.Parse("FIXED-GUID-FOR-WORKFLOW-DEF");
// Bad: Random keys (won't find saved state)
var foundryKey = Guid.NewGuid(); // Different every time!
Operation Order
Keep workflow operation order stable across versions:
// Version 1
workflow
.AddOperation("ValidateOrder")
.AddOperation("ChargePayment")
.Build();
// Version 2 - OK: Append new operations
workflow
.AddOperation("ValidateOrder")
.AddOperation("ChargePayment")
.AddOperation("SendNotification") // New operation
.Build();
// Version 2 - BAD: Reorder existing operations
workflow
.AddOperation("ChargePayment") // Order changed!
.AddOperation("ValidateOrder") // Recovery will break
.Build();
State Restoration
Ensure necessary state is in foundry.Properties:
// Good: Store state in properties
foundry.SetProperty("OrderId", orderId);
foundry.SetProperty("CustomerId", customerId);
foundry.SetProperty("PaymentId", paymentId);
// Operations can access this state after recovery
var orderId = foundry.GetPropertyOrDefault<string>("OrderId");
Recovery Flow
Load Snapshot: Retrieve saved workflow state from provider
Restore Properties: Populate foundry with saved properties
Skip Completed: Start from NextOperationIndex
Resume Execution: Continue workflow from checkpoint
Retry on Failure: Use recovery policy for transient failures
