Skip to content

Commit d8f5403

Browse files
committed
Fix log
1 parent 8cfd314 commit d8f5403

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -234,11 +234,10 @@ object ShardManager {
234234
filteredPods.map { case (k, v) => k -> PodWithMetadata(v, cdt) },
235235
(1 to config.numberOfShards).map(_ -> None).toMap ++ filteredAssignments
236236
)
237-
_ <-
238-
ZIO.logInfo(
239-
s"Recovered pods ${filteredPods
240-
.mkString("[", ", ", "]")} and assignments ${filteredAssignments.view.flatMap(_._2).mkString("[", ", ", "]")}"
241-
)
237+
_ <- ZIO.logInfo(
238+
s"Recovered pods ${filteredPods
239+
.mkString("[", ", ", "]")} and assignments ${filteredAssignments.mkString("[", ", ", "]")}"
240+
)
242241
_ <- ManagerMetrics.pods.incrementBy(initialState.pods.size)
243242
_ <- ZIO.foreachDiscard(initialState.shards) { case (_, podAddressOpt) =>
244243
podAddressOpt match {

0 commit comments

Comments
 (0)