* Atomically inserts a whole flow (tree) of jobs that may span multiple * queues, returning one `[error, idOrCode]` tuple per entry in the same

Add an item to the queue

Add a single job, routing it to the correct initial state. Returns the job id.

* Add a job to the queue. * * @param Job $job * @return string The job ID */

* Adds the job to Redis. * * @param client - The Redis client to use for adding the job. * @param parentOpts - Options for the parent-child r

* Logs one row of job's log data. * * @param jobId - The job id to log against. * @param logRow - String with log data to be logged. * @pa

Register or override a job scheduler and queue its next iteration. Returns a `[jobId, delay]` pair. Raises if the script returns a

Register/override a scheduler and enqueue its next iteration. Returns a ``(job_id, delay)`` pair for the newly-scheduled iteration, o

* Registers a job scheduler and enqueues its next delayed iteration. * The scheduler stores the template data/options so subsequent iterations *

Add many jobs in a single efficient operation. Returns the ids, in order.

Append a row to a job's log, optionally trimming old entries.

Queue every root node in `nodes` onto `entries`. Kept for backward compatibility with callers that don't need per-tree result

Atomically add multiple flows, applying per-queue default job options. This mirrors [`FlowProducer::add_with_opts`], but for bulk adds.

Append a child job that must complete before this job is processed.

Walk the freshly added job tree in the same pre-order the pipeline commands were queued (each node's command precedes its children's), validating the

* Prepares a job to be passed to Sandbox. * @returns

Total number of attempts before the job permanently fails.

Total number of attempts before the job permanently fails.

Set whether processing starts automatically (defaults to `true`).

Backoff strategy applied between retries.

Backoff strategy applied between retries.

Set a custom backoff-strategy function used to compute retry delays.

Encode bytes as standard (RFC 4648) base64 with padding. Mirrors Node.js `Buffer.from(s).toString('base64')`, which BullMQ uses to build Redis client

The raw dedicated blocking Redis client (falls back to the main one).

Execute a blocking BZPOPMIN command.

Calculate backoff delay for a retry attempt. Returns delay in ms, or -1 if custom backoff says don't retry.

* Cancels all tracked jobs by aborting their signals. * @param reason - Optional reason for the cancellation

* Cancels a specific job by aborting its signal. * @param jobId - The ID of the job to cancel * @param reason - Optional reason for the cancella

Cancel a specific active job.

Wait until cancellation is requested.

Datastore capability flags (e.g. ``canBlockFor1Ms``, ``canDoubleTimeout``).

* Change delay of a delayed job. * * Reschedules a delayed job by setting a new delay from the current time. * For example, calling changeDel

* Change delay of a delayed job. * * Reschedules a delayed job by setting a new delay from the current time. * For example, calling changeDel

Change the priority (and optionally lifo) of a waiting job.

* Change job priority. * * @param opts - options containing priority and lifo values. * @returns void

Check the result of an add command for error codes. The addJob Lua script returns `-5` when a referenced parent key is missing. In that case the job

Replace the child jobs.

Cleans jobs from a queue. Similar to drain but keeps jobs within a certain grace period * @returns: Id jobs from the