Skip to content

Commit 9f1eb4a

Browse files
authoredJul 22, 2024··
Keep assignments got from shard manager in updateAssignments (#135)
1 parent f341cf2 commit 9f1eb4a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed
 

‎entities/src/main/scala/com/devsisters/shardcake/Sharding.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ class Sharding private (
139139
Metrics.shards
140140
.set(assignmentsOpt.count { case (_, podOpt) => podOpt.contains(address) })
141141
.when(fromShardManager) *>
142-
(if (fromShardManager) shardAssignments.update(map => if (map.isEmpty) assignments else map)
142+
(if (fromShardManager) shardAssignments.set(assignments)
143143
else
144144
shardAssignments.update(map =>
145145
// we keep self assignments (we don't override them with the new assignments

0 commit comments

Comments
 (0)
Please sign in to comment.