From b0fec7d1ed981a4b993952ada0622d19f29ced76 Mon Sep 17 00:00:00 2001 From: Joe Fleming Date: Mon, 27 Jun 2016 14:14:06 -0700 Subject: [PATCH] don't emit on version errors --- src/worker.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/worker.js b/src/worker.js index d70e8d3..04d07b7 100644 --- a/src/worker.js +++ b/src/worker.js @@ -67,6 +67,7 @@ export default class Job extends events.EventEmitter { return updatedJob; }) .catch((err) => { + if (err.statusCode === 409) return true; this.debug(`_claimJob failed on job ${job._id}`, err); this.emit('claim_error', err); return false; @@ -95,9 +96,9 @@ export default class Job extends events.EventEmitter { }) .then(() => true) .catch((err) => { + if (err.statusCode === 409) return true; this.debug(`_failJob failed on job ${job._id}`, err); this.emit('fail_error', err); - if (err.statusCode === 409) return true; return false; }); }