From 379a8f096c9b0627881a3bce6cc7df026b3d4a63 Mon Sep 17 00:00:00 2001 From: Joe Fleming Date: Thu, 28 Apr 2016 16:24:28 -0700 Subject: [PATCH] simplify failed job update error handler --- src/worker.js | 13 +------------ 1 file changed, 1 insertion(+), 12 deletions(-) diff --git a/src/worker.js b/src/worker.js index 34e2e3d..f8a6fb0 100644 --- a/src/worker.js +++ b/src/worker.js @@ -88,18 +88,7 @@ export default class Job extends events.EventEmitter { body: { doc } }) .catch((err) => { - if (err.statusCode === 409) { - return this.client.get({ - index: job._index, - type: job._type, - id: job._id - }) - .then((jobDoc) => { - if (jobDoc._source.status === jobStatuses.JOB_STATUS_FAILED) return false; - throw err; - }); - } - + if (err.statusCode === 409) return false; throw err; }); }