We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c799d9b commit ca4135eCopy full SHA for ca4135e
tests/dragonfly/cluster_test.py
@@ -691,7 +691,12 @@ async def test_cluster_slot_ownership_changes(df_factory: DflyInstanceFactory):
691
)
692
693
# node0 should have removed "KEY1" as it no longer owns it
694
- assert await c_nodes[0].execute_command("DBSIZE") == 1
+ # deleting non owned keys is background operation therefore we add timeout to this check
695
+ @assert_eventually(times=2)
696
+ async def check_dbsize():
697
+ assert await c_nodes[0].execute_command("DBSIZE") == 1
698
+
699
+ await check_dbsize()
700
# node0 should still own "KEY0" though
701
assert (await c_nodes[0].get("KEY0")) == "value"
702
# node1 should still have "KEY2"
0 commit comments