Merge pull request #286 from an-tex/obey-refreshpolicy

obey refresh policy for bulkindex
an-tex · Nov 15, 2023 · b5cce60 · b5cce60
2 parents 100b318 + 75bb974
commit b5cce60
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/elastic/core/src/main/scala/Index.scala b/elastic/core/src/main/scala/Index.scala
@@ -92,7 +92,7 @@ abstract class Index(
   }
 
   def bulkIndexRequest(latests: Seq[Index.this.Latest]) =
-    bulk(latests.map(indexRequest))
+    bulk(latests.map(indexRequest)) refresh indexSetup.refreshPolicy
 
   def get(id: Id): Future[Option[Latest]] =
     execute(getRequest(id)).map(_.toOpt[Latest])