Skip to content
Snippets Groups Projects
Commit f7708e72 authored by zphrs's avatar zphrs
Browse files

fixed shuffle

parent dad5e460
No related branches found
No related tags found
No related merge requests found
......@@ -72,7 +72,8 @@ def basic_shuffle(conductor: ClusterConductor, dir, log: Logger):
# Remove shard 3, causing a shuffle. Move Node 2 to shard 1 so the keys should still exist, and be shuffled
conductor.remove_shard("shard3")
conductor.add_node_to_shard("shard1", conductor.get_nodes([2]))
conductor.add_node_to_shard("shard1", conductor.get_node(2))
fx.broadcast_view(conductor.get_shard_view())
r = c.get_all(0, timeout=10) # should get all of shard 1's keys
assert r.ok, f"expected ok for get, got {r.status_code}"
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment