Fixed job status when failing

This commit is contained in:
dgaubert 2016-03-31 13:36:58 +02:00
parent fd9bfe277e
commit f95e8ef7f2

View File

@ -94,7 +94,7 @@ JobRunner.prototype._run = function (job, query, callback) {
return self.jobBackend.get(job.job_id, callback); return self.jobBackend.get(job.job_id, callback);
} }
return self.jobBackend.setFailed(job, err, callback); return self.jobBackend.setFailed(job, err, query.index, callback);
} }
if (isLastQuery(job, query.index)) { if (isLastQuery(job, query.index)) {