Sleep thread to allow jobs to finish

Signed-off-by: Joshua Au <[email protected]>
opensearch-project · Dec 30, 2023 · ad1d765 · ad1d765
1 parent 7dfaa44
commit ad1d765
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...n/org/opensearch/indexmanagement/indexstatemanagement/IndexStateManagementRestTestCase.kt b/...n/org/opensearch/indexmanagement/indexstatemanagement/IndexStateManagementRestTestCase.kt
@@ -476,8 +476,6 @@ abstract class IndexStateManagementRestTestCase : IndexManagementRestTestCase()
 
     protected fun ExplainFilter.toHttpEntity(): HttpEntity = StringEntity(toJsonString(), APPLICATION_JSON)
 
-    protected fun ExplainFilter.toHttpEntity(): HttpEntity = StringEntity(toJsonString(), ContentType.APPLICATION_JSON)
-
     protected fun ChangePolicy.toHttpEntity(): HttpEntity {
         var string = "{\"${ChangePolicy.POLICY_ID_FIELD}\":\"$policyID\","
         if (state != null) {

diff --git a/...in/org/opensearch/indexmanagement/indexstatemanagement/resthandler/RestExplainActionIT.kt b/...in/org/opensearch/indexmanagement/indexstatemanagement/resthandler/RestExplainActionIT.kt
@@ -500,6 +500,9 @@ class RestExplainActionIT : IndexStateManagementRestTestCase() {
 
         removePolicyFromIndex(indexName1)
         removePolicyFromIndex(indexName2)
+
+        // wait for job to finish
+        Thread.sleep(1000)
     }
 
     fun `test explain filter failed index`() {
@@ -607,6 +610,9 @@ class RestExplainActionIT : IndexStateManagementRestTestCase() {
 
         removePolicyFromIndex(indexName1)
         removePolicyFromIndex(indexName2)
+
+        // wait for job to finish
+        Thread.sleep(1000)
     }
 
     @Suppress("UNCHECKED_CAST") // Do assertion of the response map here so we don't have many places to do suppression.