PRO

Effect Durable Workflow Queue

A durable payout settlement workflow built on the Effect 4 execution engine that now ships inside core as effect/unstable/workflow. It includes tag-first Workflow.make with a subclassed workflow, replay-safe Activity checkpoints with attempt tracking, a DurableQueue that persists an item and suspends the workflow until a worker settles it, schema-encoded tagged failures on both the workflow and the queue, and the full layer stack of WorkflowEngine, PersistedQueueFactory, and PersistedQueueStore with fire-and-forget execution, polling, and interruption helpers.

Install
npx shadcn@latest add https://ui.aryank.space/r/effect-durable-workflow-queue.json

Installs from ui.aryank.space. To add it by hand, copy the files in Files below, or register the @compronents namespace via the docs.

Visualization
payout
Effect<string, LedgerUnavailable>
worker
unknown
const ledgerEntryId = yield* DurableQueue.process(LedgerPost, payload)

A DurableQueue persists the payout and suspends the workflow until a worker settles it; the checkpoint is replay-safe, so a restart resumes at the suspend point rather than re-charging.

Files

Dependencies