rename the timeout error type

2016-06-28 17:46:06 -07:00
parent db1d282da2
commit df03738b9a
2 changed files with 2 additions and 2 deletions
--- a/src/worker.js
+++ b/src/worker.js
@@ -174,7 +174,7 @@ export default class Job extends events.EventEmitter {
      });
    }, (jobErr) => {
      // job execution failed
-      if (jobErr.type === 'WorkerTimeout') {
+      if (jobErr.type === 'WorkerTimeoutError') {
        this.debug(`Timeout on job ${job._id}`);
        this.emit('job_timeout', jobErr);
        return;