Increasing wait time for deprovision status

Signed-off-by: Joshua Palis <[email protected]>
opensearch-project · Jan 3, 2024 · cec9ad9 · cec9ad9
1 parent a5310d9
commit cec9ad9
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkRestApiIT.java b/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkRestApiIT.java
@@ -135,7 +135,7 @@ public void testCreateAndProvisionLocalModelWorkflow() throws Exception {
         Response deprovisionResponse = deprovisionWorkflow(workflowId);
         assertBusy(
             () -> { getAndAssertWorkflowStatus(workflowId, State.NOT_STARTED, ProvisioningProgress.NOT_STARTED); },
-            30,
+            60,
             TimeUnit.SECONDS
         );
     }
@@ -199,7 +199,7 @@ public void testCreateAndProvisionRemoteModelWorkflow() throws Exception {
         Response deprovisionResponse = deprovisionWorkflow(workflowId);
         assertBusy(
             () -> { getAndAssertWorkflowStatus(workflowId, State.NOT_STARTED, ProvisioningProgress.NOT_STARTED); },
-            30,
+            60,
             TimeUnit.SECONDS
         );
     }
@@ -237,7 +237,7 @@ public void testCreateAndProvisionDeployedRemoteModelWorkflow() throws Exception
         Response deprovisionResponse = deprovisionWorkflow(workflowId);
         assertBusy(
             () -> { getAndAssertWorkflowStatus(workflowId, State.NOT_STARTED, ProvisioningProgress.NOT_STARTED); },
-            30,
+            60,
             TimeUnit.SECONDS
         );
     }
@@ -278,7 +278,7 @@ public void testCreateAndProvisionAgentFrameworkWorkflow() throws Exception {
         Response deprovisionResponse = deprovisionWorkflow(workflowId);
         assertBusy(
             () -> { getAndAssertWorkflowStatus(workflowId, State.NOT_STARTED, ProvisioningProgress.NOT_STARTED); },
-            30,
+            60,
             TimeUnit.SECONDS
         );
 
@@ -324,7 +324,7 @@ public void testCreateAndProvisionRegisterLocalModelWithDeployFlag() throws Exce
         Response deprovisionResponse = deprovisionWorkflow(workflowId);
         assertBusy(
             () -> { getAndAssertWorkflowStatus(workflowId, State.NOT_STARTED, ProvisioningProgress.NOT_STARTED); },
-            30,
+            60,
             TimeUnit.SECONDS
         );
     }