aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/jobs/job-scheduler.js
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib/jobs/job-scheduler.js')
-rw-r--r--server/lib/jobs/job-scheduler.js12
1 files changed, 6 insertions, 6 deletions
diff --git a/server/lib/jobs/job-scheduler.js b/server/lib/jobs/job-scheduler.js
index 589a30630..c59bf9262 100644
--- a/server/lib/jobs/job-scheduler.js
+++ b/server/lib/jobs/job-scheduler.js
@@ -76,31 +76,31 @@ function processJob (job, callback) {
76 return jobHandler.process(job.handlerInputData, function (err, result) { 76 return jobHandler.process(job.handlerInputData, function (err, result) {
77 if (err) { 77 if (err) {
78 logger.error('Error in job handler %s.', job.handlerName, { error: err }) 78 logger.error('Error in job handler %s.', job.handlerName, { error: err })
79 return onJobError(jobHandler, job, callback) 79 return onJobError(jobHandler, job, result, callback)
80 } 80 }
81 81
82 return onJobSuccess(jobHandler, job, callback) 82 return onJobSuccess(jobHandler, job, result, callback)
83 }) 83 })
84 }) 84 })
85} 85}
86 86
87function onJobError (jobHandler, job, callback) { 87function onJobError (jobHandler, job, jobResult, callback) {
88 job.state = constants.JOB_STATES.ERROR 88 job.state = constants.JOB_STATES.ERROR
89 89
90 job.save().asCallback(function (err) { 90 job.save().asCallback(function (err) {
91 if (err) return cannotSaveJobError(err, callback) 91 if (err) return cannotSaveJobError(err, callback)
92 92
93 return jobHandler.onError(err, job.id, callback) 93 return jobHandler.onError(err, job.id, jobResult, callback)
94 }) 94 })
95} 95}
96 96
97function onJobSuccess (jobHandler, job, callback) { 97function onJobSuccess (jobHandler, job, jobResult, callback) {
98 job.state = constants.JOB_STATES.SUCCESS 98 job.state = constants.JOB_STATES.SUCCESS
99 99
100 job.save().asCallback(function (err) { 100 job.save().asCallback(function (err) {
101 if (err) return cannotSaveJobError(err, callback) 101 if (err) return cannotSaveJobError(err, callback)
102 102
103 return jobHandler.onSuccess(err, job.id, callback) 103 return jobHandler.onSuccess(err, job.id, jobResult, callback)
104 }) 104 })
105} 105}
106 106