Workflow Engine is here — v2.7.0

[egeominotti]

Workflow Engine — Multi-Step Orchestration for Bun

We just shipped v2.7.0 with a brand-new Workflow Engine built on top of bunqueue. Orchestrate multi-step business processes with a fluent TypeScript DSL — no new infrastructure, no YAML, no external services.

What you get

• Step chaining — .step().step().step() with automatic context passing between steps
• Saga compensation — Attach compensate handlers; on failure they run in reverse, rolling back payments, reservations, database writes
• Conditional branching — .branch().path("vip", ...).path("basic", ...) routes execution based on runtime data
• Human-in-the-loop — .waitFor("approval") pauses execution (persisted to SQLite); engine.signal() resumes it minutes, hours, or days later
• Step timeouts — Prevent steps from hanging indefinitely
• SQLite persistence — Execution state survives process restarts
• Embedded & TCP — Works in both modes, just like Queue and Worker

Quick example

import { Workflow, Engine } from "bunqueue/workflow";

const flow = new Workflow("order-pipeline")
  .step("validate", async (ctx) => {
    const { orderId, amount } = ctx.input;
    if (amount <= 0) throw new Error("Invalid amount");
    return { orderId, validated: true };
  })
  .step("charge", async (ctx) => {
    return { txId: await payments.charge(ctx.input.amount) };
  }, {
    compensate: async () => await payments.refund(),
  })
  .waitFor("manager-approval")
  .step("ship", async (ctx) => {
    const approval = ctx.signals["manager-approval"];
    return { shipped: true };
  });

const engine = new Engine({ embedded: true });
engine.register(flow);
const run = await engine.start("order-pipeline", { orderId: "ORD-1", amount: 99.99 });

// Later, when the manager approves:
await engine.signal(run.id, "manager-approval", { approved: true });

Why not Temporal / Inngest / Step Functions?

	bunqueue	Temporal	Inngest	AWS Step Functions
Infrastructure	None (embedded SQLite)	PostgreSQL + 7 services	Cloud-only	AWS-native
Saga compensation	Built-in	Manual	Manual	Manual
Human-in-the-loop	.waitFor() + signal()	Signals API	step.waitForEvent()	Callback tasks
Self-hosted	Zero-config	Complex	No	No
Pricing	Free (MIT)	Free / Cloud $$	Per-execution	Per-transition
Setup time	bun add bunqueue	Hours to days	Minutes (cloud)	Minutes (if on AWS)

bunqueue is the only workflow engine where saga compensation is first-class — every competitor requires you to implement rollback manually.

Tested thoroughly

• 27 unit tests (core engine, realistic scenarios, E2E production simulations)
• 7 embedded integration tests
• 6 TCP integration tests
• All 5274 existing tests still pass

Get started

bun add bunqueue

import { Workflow, Engine } from "bunqueue/workflow";

Full documentation: bunqueue.dev/guide/workflow

---

Would love to hear your feedback, use cases, and feature requests. What workflows would you build with this?

[gerardatkonvo]

Amazing work as always