Skip to content

Commit

Permalink
sync to 0.9.50
Browse files Browse the repository at this point in the history
  • Loading branch information
mikeTWC1984 committed May 13, 2024
1 parent 46e5c2e commit d9c23fc
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions lib/job.js
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down

0 comments on commit d9c23fc

Please sign in to comment.