From 75bb974cca9dd3ed773379e17ef44b10d04a23d9 Mon Sep 17 00:00:00 2001 From: Andreas Gabor Date: Mon, 28 Aug 2023 10:51:16 +0200 Subject: [PATCH] obey refresh policy for bulkindex --- elastic/core/src/main/scala/Index.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/elastic/core/src/main/scala/Index.scala b/elastic/core/src/main/scala/Index.scala index 0dd21c7..89f9524 100644 --- 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])