effect-mqBackground jobs for Effect.

Schema-typed payloads, swappable storage, and at-least-once execution in one package.

Effect-native

Jobs are schemas, handlers are Effects, workers are Layers. Interruption, retries, and timeouts run on the Effect runtime instead of bolted-on process machinery.

Storage is a seam

Postgres through your drizzle schema, Redis through atomic Lua scripts, memory for tests. One conformance suite keeps every driver honest.

Producer / runner split

Enqueueing never requires a Worker, and the type system enforces it. Ship producers in your API and runners on separate machines.

Operable

Run ledger, metadata queries, repeatable schedules with exactly-once ticks, dedup modes, cancellation of running jobs, tracing and metrics.

The whole idea, in one file

import { Job, Worker } from "effect-mq"
import { DrizzleJobStore } from "effect-mq/drizzle-postgres"
import { Effect, Layer, Schema } from "effect"

// 1. Define once: shared by producers and runners.
class GenerateInvoice extends Job.make("generate-invoice", {
  payload: { invoiceId: Schema.String },
  idempotencyKey: ({ invoiceId }) => invoiceId,
  defaults: { attempts: 5, backoff: { type: "exponential", delay: "1 second" } }
}) {}

// 2. Produce: needs the store, never the worker.
const jobId = yield* GenerateInvoice.enqueue({ invoiceId: "inv_123" })

// 3. Run: a layer, wherever you deploy it.
const RunnerLive = GenerateInvoice.toLayer(
  ({ invoiceId }) => Effect.log(`rendering ${invoiceId}`),
  { concurrency: 5 }
).pipe(Layer.provideMerge(Worker.layer()))

bun add effect-mq   # or npm / pnpm / yarn