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

… set it to the current time of request execution. (#1036) Signed-off-by: Oleg Kravchuk <[email protected]> (cherry picked from commit 6810b0c) Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
opensearch-project · Nov 9, 2023 · 11f3672 · 11f3672
1 parent 11aa446
commit 11f3672
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