diff --git a/lib/job/run.js b/lib/job/run.js index d49f8e1e9..390895e22 100644 --- a/lib/job/run.js +++ b/lib/job/run.js @@ -18,13 +18,17 @@ module.exports = function() { self.computeNextRunAt(); await self.save(); - const jobCallback = async err => { + const jobCallback = async(err, result) => { if (err) { self.fail(err); } else { self.attrs.lastFinishedAt = new Date(); } + if (result) { + self.attrs.result = result; + } + self.attrs.lockedAt = null; await self.save().catch(err => {