diff --git a/src/helpers/errors.js b/src/helpers/errors.js index 00e3e7a..3fe368d 100644 --- a/src/helpers/errors.js +++ b/src/helpers/errors.js @@ -3,7 +3,7 @@ import typedError from 'error/typed'; const errors = {}; errors.WorkerTimeoutError = typedError({ - type: 'WorkerTimeout', + type: 'WorkerTimeoutError', message: 'worker timed out, timeout={timeout}', timeout: null, jobId: null diff --git a/src/worker.js b/src/worker.js index acc4fa3..23c4b2e 100644 --- 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;