We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 71dfe6b commit 653cacdCopy full SHA for 653cacd
manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala
@@ -154,7 +154,7 @@ class ShardManager(
154
.map(_.flatten[PodAddress].toSet)
155
failedPods = failedPingedPods ++ failedUnassignedPods ++ failedAssignedPods
156
// check if failing pods are still up
157
- _ <- ZIO.foreachDiscard(failedPods)(notifyUnhealthyPod).forkDaemon
+ _ <- ZIO.foreachDiscard(failedPods)(notifyUnhealthyPod(_)).forkDaemon
158
_ <- ZIO.logWarning(s"Failed to rebalance pods: $failedPods").when(failedPods.nonEmpty)
159
// retry rebalancing later if there was any failure
160
_ <- (Clock.sleep(config.rebalanceRetryInterval) *> rebalance(rebalanceImmediately)).forkDaemon
0 commit comments