mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-10 18:05:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fix test: test_cluster_slot_ownership_changes (#4865)

Browse source 
Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
adiholden 2025-03-31 17:51:07 +03:00 • committed by GitHub
parent e5a0a97555
commit 0e08f22167
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
tests/dragonfly/cluster_test.py
View file

@ -693,10 +693,10 @@ async def test_cluster_slot_ownership_changes(df_factory: DflyInstanceFactory):
# node0 should have removed "KEY1" as it no longer owns it
# deleting non owned keys is background operation therefore we add timeout to this check
@assert_eventually(times=2)
async def check_dbsize():
assert await c_nodes[0].execute_command("DBSIZE") == 1
async def check_dbsize(node_index, expected_size):
assert await c_nodes[node_index].execute_command("DBSIZE") == expected_size
await check_dbsize()
await check_dbsize(node_index=0, expected_size=1)
# node0 should still own "KEY0" though
assert (await c_nodes[0].get("KEY0")) == "value"
# node1 should still have "KEY2"
@ -734,7 +734,7 @@ async def test_cluster_slot_ownership_changes(df_factory: DflyInstanceFactory):
assert await c_nodes[0].execute_command("DBSIZE") == 1
assert (await c_nodes[0].get("KEY0")) == "value"
assert await c_nodes[1].execute_command("DBSIZE") == 0
await check_dbsize(node_index=1, expected_size=0)
# Tests that master commands to the replica are applied regardless of slot ownership