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
Python
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' } },
]);
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" } }
])
This call can only succeed or fail, and all or none of the jobs will be added.
Last modified 10d ago