Automattic / kue

Kue is a priority job queue backed by redis, built for node.js.
http://automattic.github.io/kue
MIT License
9.45k stars 862 forks source link

Communicate with job #1243

Open Tobjoern opened 4 years ago

Tobjoern commented 4 years ago

Hey there, Thanks for the amazing library! I'm wondering if it is possible to communicate with a job after it was created. In my specific example merely changing the data property would be sufficient. I found out how to do it, but the change of the job is not reflected in the worker (I use clustering).

                            Job.get(rId, (err, job) => {
                                if (job) {
                                    (job.data as QueueRenderPayloadData).shouldStop = true
                                }
                            })

I also tried to emit function: Job.get(rId, (err, job) => { if (job) { const emitWorked = job.emit('customevent', { stop: true }) } })

But emitWorked is always false, is there something to keep in mind when using clustering and emitting?

Thanks for your help!