Interval schedule should take start time from the request, should not set it to the current time of request execution. (opensearch-project#1036)

ikibo · Joshua152 · commit e5d509790440 · 2023-12-11T20:10:53.000-05:00
Signed-off-by: Oleg Kravchuk &lt;oleg.ikibo@gmail.com&gt;
Signed-off-by: Joshua Au &lt;joshuahyau@gmail.com&gt;
diff --git a/src/main/kotlin/org/opensearch/indexmanagement/transform/model/Transform.kt b/src/main/kotlin/org/opensearch/indexmanagement/transform/model/Transform.kt
@@ -387,7 +387,7 @@ data class Transform(
             if (seqNo == SequenceNumbers.UNASSIGNED_SEQ_NO || primaryTerm == SequenceNumbers.UNASSIGNED_PRIMARY_TERM) {
                 // we instantiate the start time
                 if (schedule is IntervalSchedule) {
-                    schedule = IntervalSchedule(Instant.now(), schedule.interval, schedule.unit)
+                    schedule = IntervalSchedule(schedule.startTime, schedule.interval, schedule.unit)
                 }
 
                 // we clear out metadata if its a new job

Original file line number	Diff line number	Diff line change
`@@ -387,7 +387,7 @@ data class Transform(`
`387`	`387`	`if (seqNo == SequenceNumbers.UNASSIGNED_SEQ_NO \|\| primaryTerm == SequenceNumbers.UNASSIGNED_PRIMARY_TERM) {`
`388`	`388`	`// we instantiate the start time`
`389`	`389`	`if (schedule is IntervalSchedule) {`
`390`		`- schedule = IntervalSchedule(Instant.now(), schedule.interval, schedule.unit)`
	`390`	`+ schedule = IntervalSchedule(schedule.startTime, schedule.interval, schedule.unit)`
`391`	`391`	`}`
`392`	`392`
`393`	`393`	`// we clear out metadata if its a new job`