Remove logic to refresh assignments from shard manager (#150)

devsisters · Nov 20, 2024 · a32a997 · a32a997
1 parent 5b460e7
commit a32a997
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala b/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala
@@ -250,12 +250,7 @@ class Sharding private (
             )
             .map(_ isEqual cdt)
         )
-        ZIO.whenZIO(notify)(
-          (shardManager.notifyUnhealthyPod(pod) *>
-            // just in case we missed the update from the pubsub, refresh assignments
-            shardManager.getAssignments
-              .flatMap[Any, Throwable, Unit](updateAssignments(_, replaceAllAssignments = false))).forkDaemon
-        )
+        ZIO.whenZIO(notify)(shardManager.notifyUnhealthyPod(pod).forkDaemon)
       }
 
   private def sendToSelf[Msg, Res](