BullMQ
Search…
Cancelation
As mentioned, Observables allows for clean cancellation. Currently we support a TTL value that defines the maximum processing time before the job is finally cancelled:
import { WorkerPro } from '@taskforcesh/bullmq-pro';
const worker = new WorkerPro(queueName, processor, {
ttl: 100,
connection,
});
This parameter allows to provide ttl values per job name too:
const worker = new WorkerPro(queueName, processor, {
ttl: { test1: 100, test2: 200 },
connection,
});
Copy link