w33ble/elastiq
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

don't emit on version errors

Browse Source
This commit is contained in:
Joe Fleming
2016-06-27 14:14:06 -07:00
parent 638c896e37
commit b0fec7d1ed
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/worker.js
View File

@@ -67,6 +67,7 @@ export default class Job extends events.EventEmitter {
return updatedJob; return updatedJob;
}) })
.catch((err) => { .catch((err) => {
if (err.statusCode === 409) return true;
this.debug(`_claimJob failed on job ${job._id}`, err); this.debug(`_claimJob failed on job ${job._id}`, err);
this.emit('claim_error', err); this.emit('claim_error', err);
return false; return false;
@@ -95,9 +96,9 @@ export default class Job extends events.EventEmitter {
}) })
.then(() => true) .then(() => true)
.catch((err) => { .catch((err) => {
if (err.statusCode === 409) return true;
this.debug(`_failJob failed on job ${job._id}`, err); this.debug(`_failJob failed on job ${job._id}`, err);
this.emit('fail_error', err); this.emit('fail_error', err);
if (err.statusCode === 409) return true;
return false; return false;
}); });
} }