bull
bull copied to clipboard
Premium Queue package for handling distributed jobs and messages in NodeJS.
## Description I have a worker in a separate process (sanboxed). ``` const worker = path.resolve(__dirname, 'worker.js'); queue.process(2, worker); ``` But whenever this worker terminates or force killed like a...
Apparently it's not possible to update/edit the cron timers without manually flushing the database or removing the repeating job. They will always remain the same. Below a code snippet to...
## Description Hi all, thanks for this great work. I been researching the killing of waiting and active jobs (#114, #1098, #812, #1432). I see the need for a killing...
I am getting an `UnhandledPromiseRejectionWarning` when ECONNREFUSED is thrown on initial connection. ```javascript const Queue = require('bull'); const q = new Queue('test', 'redis://localhost:8009'); // no redis instance here q.on('error', e...
If I understand correctly, repeatable jobs are created via `queue.add()` by passing the `repeat` option as described e.g. [here](https://docs.bullmq.io/guide/jobs/repeatable). When calling [getRepeatableJobs](https://github.com/taskforcesh/bullmq/blob/master/docs/gitbook/api/bullmq.queue.getrepeatablejobs.md), however, all of the data that was passed...
1. Fix for call job.lockKey in scripts.js (it is function, but called as property) 2. Possibility to take lock without checking key existance
Try to resolve #1239 * `immediately` not implemented with `cron` * my changes in the `createNextJob` function are not pretty, maybe add a `delete opts.immediately` should be better because with...
Created optional setting for child pool, default is set to `true` - always retains child processes, but when set to `false` the child process is killed and not retained after...
The best way to abort the jobs running in the current process and release their locks before exiting
Hi. I'm trying to implement a "graceful stop" sequence for a worker process which happens when e.g. a machine is stopping. The idea is to call `queue.pause(true)`, then wait for...