Instantiate a Queue object

RedisConnection class

Instantiate a FlowProducer object

PostgreSQL adapter implementing :class:`~bullmq.backend.Backend`.

Owns a Postgres connection + a lazily-established dedicated LISTEN connection.

Owner of an `AbortSignal`. `abort(reason)` is idempotent so callers do not need to guard against double-cancellation when several code paths (

This class represents a Job in the queue. Normally job are implicitly created when you add a job to the queue with methods such as Queue.addJ

Listen to the global event stream of a queue. Construct one instance per queue you want to observe and add listeners via `on(event, fn)`.

This class handles all keys parser logic.

Redis adapter implementing :class:`~bullmq.backend.Backend`.

Raised when job is moved to failed without more retries

A LISTEN connection that never receives a NOTIFY (blocks until timeout).

Raised by `AbortSignal.throw_if_aborted()` (and conventionally by processors that want to surface external cancellation as a failure).

Manage repeatable job factories ("job schedulers") on a Queue. A `JobScheduler` instance is bound to a single `Queue`; it does not own a

Read-only view of an `AbortController`. Mirrors the subset of the JavaScript `AbortSignal` interface that BullMQ workers rely on: `aborted`, `

Raised when job is moved to delayed from inside the processor

A lightweight queue view used by :class:`FlowProducer` for each node in a flow. It carries the node's queue identity and a backend scoped to

<summary> Minimal, dependency-free MessagePack encoder used to build the <c>ARGV</c> payloads consumed by the shared Lua scripts (which decode them wi

A lightweight query result: column names, rows, and affected-row count.

Lightweight publisher for the queue's events stream. Unlike `QueueEvents`, no dedicated connection is required because XADD is non-blocki