[Test] increase the wait time after transform job triggered

Signed-off-by: bowenlan-amzn <[email protected]>
bowenlan-amzn · Oct 11, 2023 · 9ed9b15 · 9ed9b15
1 parent 3ddd75a
commit 9ed9b15
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...st/kotlin/org/opensearch/indexmanagement/indexstatemanagement/action/TransformActionIT.kt b/...st/kotlin/org/opensearch/indexmanagement/indexstatemanagement/action/TransformActionIT.kt
@@ -276,7 +276,7 @@ class TransformActionIT : IndexStateManagementRestTestCase() {
 
         // Change the start time so that the transform action will be attempted.
         updateManagedIndexConfigStartTime(managedIndexConfig)
-        waitFor {
+        waitFor(timeout = Instant.ofEpochSecond(60)) {
             assertEquals(
                 WaitForTransformCompletionStep.getJobCompletionMessage(transformId, indexName),
                 getExplainManagedIndexMetaData(indexName).info?.get("message")
@@ -312,7 +312,7 @@ class TransformActionIT : IndexStateManagementRestTestCase() {
 
         // Change the start time so that the transform action will be attempted.
         updateManagedIndexConfigStartTime(managedIndexConfig)
-        waitFor {
+        waitFor(timeout = Instant.ofEpochSecond(60)) {
             assertEquals(
                 WaitForTransformCompletionStep.getJobCompletionMessage(transformId, indexName),
                 getExplainManagedIndexMetaData(indexName).info?.get("message")
@@ -347,7 +347,7 @@ class TransformActionIT : IndexStateManagementRestTestCase() {
 
         // Change the start time so that the second transform action will be attempted.
         updateManagedIndexConfigStartTime(managedIndexConfig)
-        waitFor {
+        waitFor(timeout = Instant.ofEpochSecond(60)) {
             assertEquals(
                 WaitForTransformCompletionStep.getJobCompletionMessage(transformId, indexName),
                 getExplainManagedIndexMetaData(indexName).info?.get("message")