Correctly compute completed backfills (#123)

criteo · Jul 19, 2017 · 15553cd · 15553cd
1 parent 4ffd3b4
commit 15553cd
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/timeseries/src/main/scala/com/criteo/cuttle/timeseries/TimeSeriesScheduler.scala b/timeseries/src/main/scala/com/criteo/cuttle/timeseries/TimeSeriesScheduler.scala
@@ -251,10 +251,9 @@ case class TimeSeriesScheduler() extends Scheduler[TimeSeries] with TimeSeriesAp
           val itvl = Interval(bf.start, bf.end)
           !bf.jobs.forall(job => _state().apply(job).intersect(itvl).toList.forall(_._2 == Done))
         }
-
         val _toRun = next(workflow, _state(), now)
 
-        (_state(), _backfills.snapshot -- oldBackfills, _toRun)
+        (_state(), oldBackfills -- _backfills.snapshot, _toRun)
       }
 
       val newExecutions = executor.runAll(toRun)