Fix log

devsisters · Oct 30, 2024 · d8f5403 · d8f5403
1 parent 8cfd314
commit d8f5403
Showing 1 changed file with 4 additions and 5 deletions.
diff --git 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 {