Fix index refresh issue

Signed-off-by: Nishant Bhagat <[email protected]>
opensearch-project · Oct 18, 2023 · ce4e398 · ce4e398
1 parent 0e55d38
commit ce4e398
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/...tifications/src/main/kotlin/org/opensearch/notifications/index/NotificationConfigIndex.kt b/...tifications/src/main/kotlin/org/opensearch/notifications/index/NotificationConfigIndex.kt
@@ -182,7 +182,7 @@ internal object NotificationConfigIndex : ConfigOperations {
      */
     override suspend fun createNotificationConfig(configDoc: NotificationConfigDoc, id: String?): String? {
         createIndex()
-        val indexRequest = IndexRequest(INDEX_NAME)
+        val indexRequest = IndexRequest(INDEX_NAME).setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE)
             .source(configDoc.toXContent())
             .create(true)
         if (id != null) {

diff --git a/...ications/src/test/kotlin/org/opensearch/integtest/config/ChimeNotificationConfigCrudIT.kt b/...ications/src/test/kotlin/org/opensearch/integtest/config/ChimeNotificationConfigCrudIT.kt
@@ -41,7 +41,6 @@ class ChimeNotificationConfigCrudIT : PluginRestTestCase() {
         """.trimIndent()
         val configId = createConfigWithRequestJsonString(createRequestJsonString)
         Assert.assertNotNull(configId)
-        Thread.sleep(1000)
 
         // Get chime notification config