BullMQ icon

BullMQ

Add jobs to BullMQ

BullMQ

AI-generated

Summary

Adds one job per input item to a BullMQ queue stored in Redis, and returns the created job's id, name and data.

Inputs

  • Queue Name (required) — Name of the BullMQ queue. It is read once, from the first item, and used for every item in the run.
  • Job Name (required) — Name given to each job (default "job"). It is evaluated per item, so expressions work.
  • Job Data (required) — JSON payload for the job. It defaults to the expression {{$json}}, which is the incoming item's data.
  • Options — Optional collection with Attempts (default 3), Delay in ms (default 0), Backoff Type (fixed or exponential) and Backoff Delay in ms (default 1000). Backoff is applied only when both type and delay are set.
  • Redis credential (required) — The 'redis' credential supplies the host, port, password and db used to connect.

Output shape

A list of items, one per input item. Each has json with id (the job ID), name and data (the job payload).

If Continue On Fail is enabled, a failed item returns {error: message} instead of stopping the run. Otherwise the first error is thrown. The node only enqueues jobs. It does not wait for them to be processed or return their results. The queue connection is opened once per execution and closed at the end.

Examples

Example 1: Queue an email job for each incoming row

Queue Name: emails; Job Name: send; Job Data: {{$json}}; Redis credential set.

Example 2: Schedule a job to run in 1 minute with retries

Options: Delay 60000, Attempts 5, Backoff Type fixed, Backoff Delay 5000.

Links

Discussion