Adding jobs in bulk

Sometimes it is necessary to add many jobs atomically. For example, there could be a requirement that all the jobs must be placed in the queue or none of them. Also, adding jobs in bulk can be faster since it reduces the number of roundtrips to Redis:

TypeScript

import { Queue } from 'bullmq';

const queue = new Queue('paint');

const name = 'jobName';
const jobs = await queue.addBulk([
  { name, data: { paint: 'car' } },
  { name, data: { paint: 'house' } },
  { name, data: { paint: 'boat' } },
]);

Python

from bullmq import Queue

queue = Queue("paint")

jobs = await queue.addBulk([
  { "name": "jobName", "data": { "paint": "car" } },
  { "name": "jobName", "data": { "paint": "house" } },
  { "name": "jobName", "data": { "paint": "boat" } }
])

Rust

use bullmq::{Queue, QueueOptions};

let queue = Queue::new("paint", QueueOptions::default()).await?;

let jobs = queue.add_bulk(vec![
    ("jobName".into(), serde_json::json!({"paint": "car"}), None),
    ("jobName".into(), serde_json::json!({"paint": "house"}), None),
    ("jobName".into(), serde_json::json!({"paint": "boat"}), None),
]).await?;

This call can only succeed or fail, and all or none of the jobs will be added.

Read more:

• 💡 Add Bulk API Reference