Give time for state doc deletion to replicate

Signed-off-by: Daniel Widdis <[email protected]>
opensearch-project · Apr 30, 2024 · f5d15be · f5d15be
1 parent 57e1c79
commit f5d15be
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkSecureRestApiIT.java b/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkSecureRestApiIT.java
@@ -161,6 +161,9 @@ public void testCreateProvisionDeprovisionWorkflowWithFullAccess() throws Except
         response = deleteWorkflow(fullAccessClient(), workflowId);
         assertEquals(RestStatus.OK, TestHelpers.restStatus(response));
 
+        // Give time for state deletion to replicate
+        Thread.sleep(1000);
+
         // Invoke status API with failure
         exception = expectThrows(ResponseException.class, () -> getWorkflowStatus(fullAccessClient(), newWorkflowId, false));
         assertEquals(RestStatus.NOT_FOUND.getStatus(), exception.getResponse().getStatusLine().getStatusCode());