Durable background jobs on the Postgres you already run.

import { FlowKeeper, defineWorkflow } from "@flow-keeper/core";

const fk = new FlowKeeper({ connection: process.env.DATABASE_URL });

const checkout = defineWorkflow("checkout", async (ctx, order) => {
  const charge = await ctx.step("charge-card", () =>
    stripe.charge(order));               // retries with backoff on failure

  await ctx.step("send-receipt", () =>
    email.receipt(order, charge));       // memoized — replays skip completed steps

  await ctx.sleep("wait-1-day", 86_400_000);   // durable. survives restarts.

  await ctx.step("ask-for-review", () => email.review(order));
});

fk.register(checkout).start();
await fk.trigger("checkout", order, { idempotencyKey: order.id });