BullMQ
Search
K

Removing jobs

Sometimes it is necessary to remove a job. For example, there could be a job that has bad data.
TypeScript
Python
import { Queue } from 'bullmq';
const queue = new Queue('paint');
const job = await queue.add('wall', { color: 1 });
await job.remove();
from bullmq import Queue
queue = Queue('paint')
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:
  1. 1.
    There are not pending dependencies; in this case the parent is moved to wait status, we may try to process this job.
  2. 2.
    There are pending dependencies; in this case the parent is kept in waiting-children status.
Take into consideration that processed values will be kept in processed hset from the parent if this child is in completed state at the time when it's removed.

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 modified 10d ago
Copyright (c) Taskforce.sh Inc.