From 653cacd381ae1ca1159615d527374176695dea38 Mon Sep 17 00:00:00 2001 From: Pierre Ricadat Date: Tue, 5 Nov 2024 10:28:06 +0900 Subject: [PATCH] Fix --- .../src/main/scala/com/devsisters/shardcake/ShardManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala b/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala index 065bfa9..e4e6201 100644 --- a/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala +++ b/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala @@ -154,7 +154,7 @@ class ShardManager( .map(_.flatten[PodAddress].toSet) failedPods = failedPingedPods ++ failedUnassignedPods ++ failedAssignedPods // check if failing pods are still up - _ <- ZIO.foreachDiscard(failedPods)(notifyUnhealthyPod).forkDaemon + _ <- ZIO.foreachDiscard(failedPods)(notifyUnhealthyPod(_)).forkDaemon _ <- ZIO.logWarning(s"Failed to rebalance pods: $failedPods").when(failedPods.nonEmpty) // retry rebalancing later if there was any failure _ <- (Clock.sleep(config.rebalanceRetryInterval) *> rebalance(rebalanceImmediately)).forkDaemon