diff --git a/src/constants/events.js b/src/constants/events.js index 8d2c952..1fcfeb6 100644 --- a/src/constants/events.js +++ b/src/constants/events.js @@ -10,5 +10,5 @@ export default { EVENT_WORKER_JOB_FAIL: 'worker:job failed', EVENT_WORKER_JOB_FAIL_ERROR: 'worker:failed job update error', EVENT_WORKER_JOB_EXECUTION_ERROR: 'worker:job execution error', - EVENT_WORKER_JOB_TIMEOUT_ERROR: 'worker:job timeout', + EVENT_WORKER_JOB_TIMEOUT: 'worker:job timeout', }; diff --git a/src/worker.js b/src/worker.js index 6cb81b4..4ef9dbe 100644 --- a/src/worker.js +++ b/src/worker.js @@ -212,7 +212,7 @@ export default class Job extends events.EventEmitter { output: docOutput, }; - this.emit(constants.EVENT_WORKER_COMPLETE, eventOutput) + this.emit(constants.EVENT_WORKER_COMPLETE, eventOutput); }) .catch((err) => { if (err.statusCode === 409) return false; @@ -229,7 +229,7 @@ export default class Job extends events.EventEmitter { // job execution failed if (jobErr.type === 'WorkerTimeoutError') { this.debug(`Timeout on job ${job._id}`); - this.emit(constants.EVENT_WORKER_JOB_TIMEOUT_ERROR, this._formatErrorParams(jobErr, job)); + this.emit(constants.EVENT_WORKER_JOB_TIMEOUT, this._formatErrorParams(jobErr, job)); return; } diff --git a/test/src/worker.js b/test/src/worker.js index 002959c..5c96af2 100644 --- a/test/src/worker.js +++ b/test/src/worker.js @@ -738,7 +738,7 @@ describe('Worker class', function () { let performJobPromise; // check for timeout event - worker.once(constants.EVENT_WORKER_JOB_TIMEOUT_ERROR, (err) => { + worker.once(constants.EVENT_WORKER_JOB_TIMEOUT, (err) => { try { expect(err).to.have.property('error'); expect(err).to.have.property('job');