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:24:05 -07:00
parent e077442340
commit aa5ea72e3b
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

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