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

swollow errors saving job output, include error in debugging output

Browse Source
This commit is contained in:
Joe Fleming
2016-05-10 17:23:07 -07:00
parent 11de18f4da
commit d1e5d68f74
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/worker.js
View File

@@ -148,7 +148,8 @@ export default class Job extends events.EventEmitter {
})
.catch((err) => {
if (err.statusCode === 409) return false;
throw err;
this.debug(`Failure saving job output ${job._id}`, err);
this.emit('job_error', err);
});
}, (jobErr) => {
// job execution failed
@@ -158,7 +159,7 @@ export default class Job extends events.EventEmitter {
return;
}
this.debug(`Failure occurred on job ${job._id}`);
this.debug(`Failure occurred on job ${job._id}`, jobErr);
this.emit('job_error', jobErr);
return this._failJob(job, jobErr.toString());
});