Interval schedule should take start time from the request, should not…

… set it to the current time of request execution. (opensearch-project#1036) Signed-off-by: Oleg Kravchuk <[email protected]> Signed-off-by: Joshua Au <[email protected]>
Joshua152 · Dec 12, 2023 · e5d5097 · e5d5097
1 parent deb7117
commit e5d5097
Showing 1 changed file with 1 addition and 1 deletion.
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