increasing getResource timeout

Signed-off-by: Joshua Palis <[email protected]>
joshpalis · Aug 14, 2024 · 85c8e18 · 85c8e18
1 parent 5ae8603
commit 85c8e18
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkRestApiIT.java b/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkRestApiIT.java
@@ -359,7 +359,7 @@ public void testReprovisionWorkflow() throws Exception {
         response = reprovisionWorkflow(client(), workflowId, template);
         assertEquals(RestStatus.CREATED, TestHelpers.restStatus(response));
 
-        resourcesCreated = getResourcesCreated(client(), workflowId, 10);
+        resourcesCreated = getResourcesCreated(client(), workflowId, 30);
         assertEquals(4, resourcesCreated.size());
         resourceIds = resourcesCreated.stream().map(x -> x.workflowStepName()).collect(Collectors.toList());
         assertTrue(resourceIds.contains("create_connector"));
@@ -386,7 +386,7 @@ public void testReprovisionWorkflow() throws Exception {
         response = reprovisionWorkflow(client(), workflowId, template);
         assertEquals(RestStatus.CREATED, TestHelpers.restStatus(response));
 
-        resourcesCreated = getResourcesCreated(client(), workflowId, 10);
+        resourcesCreated = getResourcesCreated(client(), workflowId, 30);
         assertEquals(5, resourcesCreated.size());
         resourceIds = resourcesCreated.stream().map(x -> x.workflowStepName()).collect(Collectors.toList());
         assertTrue(resourceIds.contains("create_connector"));
@@ -408,7 +408,7 @@ public void testReprovisionWorkflow() throws Exception {
         response = reprovisionWorkflow(client(), workflowId, template);
         assertEquals(RestStatus.CREATED, TestHelpers.restStatus(response));
 
-        resourcesCreated = getResourcesCreated(client(), workflowId, 10);
+        resourcesCreated = getResourcesCreated(client(), workflowId, 30);
         // resource count should remain unchanged when updating an existing node
         assertEquals(5, resourcesCreated.size());
 
@@ -459,7 +459,7 @@ public void testReprovisionWorkflowMidNodeAddition() throws Exception {
         response = reprovisionWorkflow(client(), workflowId, template);
         assertEquals(RestStatus.CREATED, TestHelpers.restStatus(response));
 
-        resourcesCreated = getResourcesCreated(client(), workflowId, 10);
+        resourcesCreated = getResourcesCreated(client(), workflowId, 30);
         assertEquals(5, resourcesCreated.size());
         resourceIds = resourcesCreated.stream().map(x -> x.workflowStepName()).collect(Collectors.toList());
         assertTrue(resourceIds.contains("create_connector"));