Delete also the former index when restarting event metrics (#5111)

Co-authored-by: Simon Dumas <simon.dumas@epfl.ch>
BlueBrain · Aug 20, 2024 · 70aeb2c · 70aeb2c
1 parent 710e1bc
commit 70aeb2c
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/...in/scala/ch/epfl/bluebrain/nexus/delta/plugins/elasticsearch/EventMetricsProjection.scala b/...in/scala/ch/epfl/bluebrain/nexus/delta/plugins/elasticsearch/EventMetricsProjection.scala
@@ -81,11 +81,12 @@ object EventMetricsProjection {
 
     for {
       shouldRestart     <- Env[IO].get("RESET_EVENT_METRICS").map(_.getOrElse("false").toBoolean)
-      _                 <- IO.whenA(shouldRestart)(
-                             logger.warn("Resetting event metrics as the env RESET_EVENT_METRICS is set") >> projections.reset(
-                               projectionMetadata.name
-                             )
-                           )
+      _                 <- IO.whenA(shouldRestart) {
+                             client.deleteIndex(index) >>
+                               logger.warn("Resetting event metrics as the env RESET_EVENT_METRICS is set") >> projections.reset(
+                                 projectionMetadata.name
+                               )
+                           }
       metricsProjection <- apply(sink, supervisor, metrics, createIndex)
     } yield (metricsProjection)