From 9a71fcc7b5d38661147b6659606f45e2530cda40 Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Mon, 11 Jul 2016 12:10:35 -0700
Subject: [PATCH] emit on any worker job failure

---
 src/worker.js | 26 +++++++++++++++++++-------
 1 file changed, 19 insertions(+), 7 deletions(-)

diff --git a/src/worker.js b/src/worker.js
index 68d0e97..bb7e7ce 100644
--- a/src/worker.js
+++ b/src/worker.js
@@ -110,15 +110,13 @@ export default class Job extends events.EventEmitter {
     this.debug(`Failing job ${job._id}`);
 
     const completedTime = moment().toISOString();
+    const docOutput = this._formatOutput(output);
     const doc = {
       status: constants.JOB_STATUS_FAILED,
       completed_at: completedTime,
+      output: docOutput
     };
 
-    if (output) {
-      doc.output = this._formatOutput(output);
-    }
-
     return this.client.update({
       index: job._index,
       type: job._type,
@@ -126,7 +124,15 @@ export default class Job extends events.EventEmitter {
       version: job._version,
       body: { doc }
     })
-    .then(() => true)
+    .then(() => {
+      const eventOutput = {
+        job: formatJobObject(job),
+        output: docOutput,
+      };
+
+      this.emit(constants.EVENT_WORKER_JOB_FAIL, eventOutput);
+      return true;
+    })
     .catch((err) => {
       if (err.statusCode === 409) return true;
       this.debug(`_failJob failed to update job ${job._id}`, err);
@@ -186,7 +192,6 @@ export default class Job extends events.EventEmitter {
       const completedTime = moment().toISOString();
       const docOutput = this._formatOutput(output);
 
-      const emitJob = { job: formatJobObject(job) };
       const doc = {
         status: constants.JOB_STATUS_COMPLETED,
         completed_at: completedTime,
@@ -200,7 +205,14 @@ export default class Job extends events.EventEmitter {
         version: job._version,
         body: { doc }
       })
-      .then(() => this.emit(constants.EVENT_WORKER_COMPLETE, Object.assign(emitJob, { output: docOutput })))
+      .then(() => {
+        const eventOutput = {
+          job: formatJobObject(job),
+          output: docOutput,
+        };
+
+        this.emit(constants.EVENT_WORKER_COMPLETE, eventOutput)
+      })
       .catch((err) => {
         if (err.statusCode === 409) return false;
         this.debug(`Failure saving job output ${job._id}`, err);