From f725824c5f5941b0435ab56354a9850e70e1a8df Mon Sep 17 00:00:00 2001 From: Joe Fleming Date: Tue, 3 May 2016 11:35:09 -0700 Subject: [PATCH] emit job fail events, don't throw --- src/worker.js | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/src/worker.js b/src/worker.js index f580575..3a38991 100644 --- a/src/worker.js +++ b/src/worker.js @@ -159,16 +159,13 @@ export default class Job extends events.EventEmitter { // job execution failed if (jobErr.type === 'WorkerTimeout') { this.debug(`Timeout on job ${job._id}`); + this.emit('job_timeout', jobErr); return; } this.debug(`Failure occurred on job ${job._id}`); - return this._failJob(job, jobErr.toString()) - .catch(() => false) - .then(() => { - this.emit('job_error', jobErr); - throw jobErr; - }); + this.emit('job_error', jobErr); + return this._failJob(job, jobErr.toString()); }); }