Interval schedule should take start time from the request, should not set it to the current time of request execution.

ikibo · ikibo · commit f62b77a11795 · 2023-11-14T21:05:38.000+02:00
Signed-off-by: Oleg Kravchuk &lt;oleg.ikibo@gmail.com&gt;
diff --git a/src/main/kotlin/org/opensearch/indexmanagement/rollup/model/Rollup.kt b/src/main/kotlin/org/opensearch/indexmanagement/rollup/model/Rollup.kt
@@ -330,7 +330,7 @@ data class Rollup(
             // TODO: Make startTime public in Job Scheduler so we can just directly check the value
             if (seqNo == SequenceNumbers.UNASSIGNED_SEQ_NO || primaryTerm == SequenceNumbers.UNASSIGNED_PRIMARY_TERM) {
                 if (schedule is IntervalSchedule) {
-                    schedule = IntervalSchedule(Instant.now(), schedule.interval, schedule.unit, schedule.delay ?: 0)
+                    schedule = IntervalSchedule(schedule.startTime, schedule.interval, schedule.unit, schedule.delay ?: 0)
                 }
             }
             return Rollup(

Original file line number	Diff line number	Diff line change
`@@ -330,7 +330,7 @@ data class Rollup(`
`330`	`330`	`// TODO: Make startTime public in Job Scheduler so we can just directly check the value`
`331`	`331`	`if (seqNo == SequenceNumbers.UNASSIGNED_SEQ_NO \|\| primaryTerm == SequenceNumbers.UNASSIGNED_PRIMARY_TERM) {`
`332`	`332`	`if (schedule is IntervalSchedule) {`
`333`		`- schedule = IntervalSchedule(Instant.now(), schedule.interval, schedule.unit, schedule.delay ?: 0)`
	`333`	`+ schedule = IntervalSchedule(schedule.startTime, schedule.interval, schedule.unit, schedule.delay ?: 0)`
`334`	`334`	`}`
`335`	`335`	`}`
`336`	`336`	`return Rollup(`