cause worker emitter to emit on the queue instance
This commit is contained in:
@@ -52,6 +52,11 @@ export default class Job extends events.EventEmitter {
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
emit(name, ...args) {
|
||||||
|
super.emit(name, ...args);
|
||||||
|
this.queue.emit(name, ...args);
|
||||||
|
}
|
||||||
|
|
||||||
_formatErrorParams(err, job) {
|
_formatErrorParams(err, job) {
|
||||||
const response = {
|
const response = {
|
||||||
error: err,
|
error: err,
|
||||||
|
|||||||
Reference in New Issue
Block a user