From d8f5403ef9b55d7aca76dce5dff466650fed08f9 Mon Sep 17 00:00:00 2001 From: Pierre Ricadat Date: Wed, 30 Oct 2024 18:55:58 +0900 Subject: [PATCH] Fix log --- .../scala/com/devsisters/shardcake/ShardManager.scala | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala b/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala index 27d5ce7..2cbbf50 100644 --- a/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala +++ b/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala @@ -234,11 +234,10 @@ object ShardManager { filteredPods.map { case (k, v) => k -> PodWithMetadata(v, cdt) }, (1 to config.numberOfShards).map(_ -> None).toMap ++ filteredAssignments ) - _ <- - ZIO.logInfo( - s"Recovered pods ${filteredPods - .mkString("[", ", ", "]")} and assignments ${filteredAssignments.view.flatMap(_._2).mkString("[", ", ", "]")}" - ) + _ <- ZIO.logInfo( + s"Recovered pods ${filteredPods + .mkString("[", ", ", "]")} and assignments ${filteredAssignments.mkString("[", ", ", "]")}" + ) _ <- ManagerMetrics.pods.incrementBy(initialState.pods.size) _ <- ZIO.foreachDiscard(initialState.shards) { case (_, podAddressOpt) => podAddressOpt match {