diff --git a/batch/job_runner.js b/batch/job_runner.js index 440c49f1..ec3fa91b 100644 --- a/batch/job_runner.js +++ b/batch/job_runner.js @@ -94,7 +94,7 @@ JobRunner.prototype._run = function (job, query, 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)) {