Remove logic to refresh assignments from shard manager

ghostdogpr · ghostdogpr · commit a6638e6534c7 · 2024-11-20T14:46:28.000+09:00
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](

Original file line number	Diff line number	Diff line change
`@@ -250,12 +250,7 @@ class Sharding private (`
`250`	`250`	`)`
`251`	`251`	`.map(_ isEqual cdt)`
`252`	`252`	`)`
`253`		`- ZIO.whenZIO(notify)(`
`254`		`- (shardManager.notifyUnhealthyPod(pod) *>`
`255`		`- // just in case we missed the update from the pubsub, refresh assignments`
`256`		`- shardManager.getAssignments`
`257`		`- .flatMap[Any, Throwable, Unit](updateAssignments(_, replaceAllAssignments = false))).forkDaemon`
`258`		`- )`
	`253`	`+ ZIO.whenZIO(notify)(shardManager.notifyUnhealthyPod(pod).forkDaemon)`
`259`	`254`	`}`
`260`	`255`
`261`	`256`	`private def sendToSelf[Msg, Res](`