Skip to content
PgWorkflows

PgWorkflows - Durable workflows built on PostgreSQL

Why PgWorkflows

Section titled “Why PgWorkflows”

PgWorkflows allows you to create durable workflows with your existing architecture. There is no longer a need to host additional software or buy into a specific ecosystem to create long-running scalable durable workflows.

Example

Section titled “Example”

PgWorkflows is easy to use and feature rich. It supports workflow orchestration such as fan-in fan-out, sleep, signals, and much more.

example.cs
[Workflow("trial-onboarding")]
public sealed class TrialOnboardingWorkflow
{
    [WorkflowRun]
    public async ValueTask<string> RunAsync(
        IWorkflowContext ctx,
        SignupInput input,
        CancellationToken cancellationToken
    )
    {
        // Fan-out: run independent activities in parallel.
        var (workspace, _) = await ctx.WhenAll(
            ctx.CallActivity((OnboardingActivities a) => a.ProvisionWorkspace(input.Company)),
            ctx.CallActivity((EmailActivities a) => a.SendWelcome(input.Email)),
            cancellationToken
        );


        // Durable timer: the run is parked in Postgres — it survives
        // restarts and deploys, and no worker holds it in memory.
        await ctx.Sleep(TimeSpan.FromDays(11), cancellationToken);


        await ctx.Activity(
            (EmailActivities a) => a.SendTrialEndingReminder(input.Email),
            cancellationToken
        );


        // Human-in-the-loop: park again until an external signal arrives.
        var decision = await ctx.WaitForSignal<UpgradeDecision>("upgrade", cancellationToken);


        if (!decision.Upgraded)
        {
            await ctx.Activity(
                (OnboardingActivities a) => a.DowngradeToFreeTier(workspace.Id),
                cancellationToken
            );
            return $"{input.Company} stayed on the free tier.";
        }


        await ctx.Activity(
            (BillingActivities a) => a.StartSubscription(workspace.Id, decision.Plan),
            cancellationToken
        );
        return $"{input.Company} upgraded to {decision.Plan}.";
    }
}


public sealed record SignupInput(string Company, string Email);


public sealed record UpgradeDecision(bool Upgraded, string Plan);

Next steps

Section titled “Next steps”

Excited to get started? Check out the following resources to learn more about PgWorkflows and how to easily use it for your projects.

Get started

Go to our get started page to create your very first workflow!