<a href="https://pgflow.dev/" target="_blank" rel="noopener noreferrer"><img src="logo-with-text.svg" alt="pgflow logo" width="450"></a> AI workflows in Supabase, no extra infra. TypeScript workflows with full autocomplete, zero boilerplate, automatic retries and realtime progress. Built on Postgres + Edge Functions. <a href="https://pgflow.dev">Docs</a> | <a href="https://demo.pgflow.dev">Demo</a> | <a href="https://github.com/pgflow-dev/pgflow">GitHub</a> | <a href="https://pgflow.dev/discord/">Discord</a> <a href="./LICENSE"><img src="https://img.shields.io/badge/license-Apache%202.0-blue" alt="License"></a> <a href="https://supabase.com"><img src="https://img.shields.io/badge/Built%20for-Supabase-3ECF8E?logo=supabase" alt="Built for Supabase"></a> "A workflow engine built on Supabase primitives." Paul Copplestone, CEO, Supabase (<a href="https://x.com/kiwicopple/status/1990686524229181856">via X</a>) <img src="dag-animation.svg" alt="pgflow DAG execution showing parallel steps with automatic retry" width="400">

Quick Start

# Install pgflow in your Supabase project
npx pgflow@latest install

# Restart Supabase and apply migrations
npx supabase stop && npx supabase start
npx supabase migrations up

Then define your workflow (full guide):

import { Flow } from '@pgflow/dsl';

new Flow<{ url: string }>({ slug: 'analyzeArticle' })
  .step({ slug: 'scrape' }, (flowInput) => scrapeWebsite(flowInput.url))
  .step({ slug: 'summarize', dependsOn: ['scrape'] }, (deps) =>
    summarize(deps.scrape)
  )
  .step({ slug: 'extractKeywords', dependsOn: ['scrape'] }, (deps) =>
    extractKeywords(deps.scrape)
  )
  .step(
    { slug: 'publish', dependsOn: ['summarize', 'extractKeywords'] },
    (deps) =>
      publish({ summary: deps.summarize, keywords: deps.extractKeywords })
  );

This replaces ~240 lines of queue setup, state management, and coordination code. See full comparison

Why pgflow?

Building workflows in Supabase today means wiring together pgmq, pg_cron, state tables, and Edge Functions yourself. It works, but it's tedious.

pgflow gives you:

Declarative workflows - Define steps and dependencies in TypeScript. pgflow handles queues, state, and coordination.
Built for Supabase - Runs entirely in your existing project. No Redis, no Temporal, no external services.
AI-ready - Automatic retries with exponential backoff for flaky LLM APIs. Per-step, not per-workflow.
Parallel processing - Fan out over arrays with independent retries. If 3 of 100 items fail, only those 3 retry.
Full observability - All workflow state in Postgres. Query runs, debug failures, inspect outputs with SQL.
Flexible triggers - Start from your app, database triggers, pg_cron, or direct SQL calls.

What can you build?

AI Pipelines - Scrape websites, chunk content, generate embeddings, summarize with LLMs. Each step retries independently when APIs flake.
Background Jobs - Process uploads, send emails, sync data. Reliable task queue processing without Redis or external services.
RAG Pipelines - Chunk documents, generate embeddings, index content. Perfect for AI applications with multi-step LLM chains.
Data Workflows - ETL pipelines, scheduled imports, multi-step transformations. All orchestrated in Postgres.

See how pgflow compares to Trigger.dev, Inngest, DBOS, and Vercel Workflows.

How it works

Define workflows using the TypeScript DSL
Compile them to SQL migrations
Deploy as Supabase Edge Functions
Trigger from your app, SQL, or pg_cron

The execution engine handles scheduling, retries, and result aggregation automatically.

Packages

| Package | Version | Description | | ------------------------------------------ | --------------------------------------------------------------------------------------------------- | ------------------------------------------------------- | | pgflow | | CLI for installing and compiling flows | | @pgflow/core | | SQL Core - foundational tables and functions | | @pgflow/dsl | | TypeScript DSL for defining flows with type inference | | @pgflow/edge-worker | | Task queue worker for Supabase Edge Functions | | @pgflow/client | | TypeScript client for starting and monitoring workflows |

Releases

Release Process: See RELEASES.md for how versions are managed and published
Snapshot Releases: See SNAPSHOT_RELEASES.md for testing changes before release

[!NOTE] This project and all its components are licensed under Apache 2.0 license.

Pgflow

Install / Use

README