emit job fail events, don't throw

2016-05-03 11:35:09 -07:00
parent 552abb7ddd
commit f725824c5f
1 changed files with 3 additions and 6 deletions
--- 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;
-      });
+      return this._failJob(job, jobErr.toString());
    });
  }