Added failed_reason to query in multiquery jobs

This commit is contained in:
dgaubert 2016-03-31 19:03:38 +02:00
parent 270cdf8969
commit 5c5c151237

View File

@ -324,6 +324,7 @@ JobBackend.prototype.setFailed = function (job, error, index, callback) {
callback = index;
} else if (index || index === 0) {
job.query[index].status = 'failed';
job.query[index].failed_reason = error.message;
redisParams = redisParams.concat('query', JSON.stringify(job.query));
}