diff --git a/lib/job.js b/lib/job.js index 3dc71fb..56f415e 100644 --- a/lib/job.js +++ b/lib/job.js @@ -954,10 +954,12 @@ module.exports = Class.create({ rewindJob: function (job) { // reset cursor state to minute before job started (use 'now' property in case start was delayed) - // only do this if job has catch_up, was launched via the scheduler, and is not multiplexed + // only do this if job has catch_up, and is not multiplexed if (!this.multi.manager) return; - if (job.catch_up && !job.source && !job.multiplex) { + // Note: manually started jobs will now be included in the rewind, as per GH #757 + + if (job.catch_up && !job.multiplex) { var new_start = Tools.normalizeTime(job.now - 60, { sec: 0 }); this.state.cursors[job.event] = new_start;