Removing jobs
Sometimes it is necessary to remove a job. For example, there could be a job that has bad data.
import { Queue } from 'bullmq';
const queue = new Queue('paint');
const job = await queue.add('wall', { color: 1 });
await job.remove();
Locked jobs (in active state) can not be removed. An error will be thrown.
Having a parent job
There are 2 possible cases:
There are not pending dependencies; in this case the parent is moved to wait status, we may try to process this job.
There are pending dependencies; in this case the parent is kept in waiting-children status.
Having pending dependencies
We may try to remove all its pending descendants first.
If any of the children are locked, the deletion process will be stopped.
Read more:
Last updated
Was this helpful?