diff --git a/src/worker.js b/src/worker.js index 3f7376f..38d710d 100644 --- a/src/worker.js +++ b/src/worker.js @@ -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) { const response = { error: err,