diff --git a/tests/proxy/basic_proxy.py b/tests/proxy/basic_proxy.py index 3dd87d3fa06d9fad19b432b129ee340bcec4827f..e2a87627e78dd5a27723a5c0ca759a4e234c1815 100644 --- a/tests/proxy/basic_proxy.py +++ b/tests/proxy/basic_proxy.py @@ -17,7 +17,7 @@ def basic_proxy(conductor: ClusterConductor, dir, log: Logger): node_to_put = 0 base_key = "key" - for i in range(0, 51): + for i in range(0, 50): r = c.put(node_to_put, f"{base_key}{i}", f"{i}", timeout=10) assert r.ok, f"expected ok for new key, got {r.status_code}" node_to_put += 1 @@ -25,8 +25,12 @@ def basic_proxy(conductor: ClusterConductor, dir, log: Logger): 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}" - res = r.json()["items"] - print("res-- {}", res) + items = r.json()["items"] + keys = items.keys() + for key in keys: + r = c.get(2, key, timeout=10) + assert r.ok, f"expected ok for get, got {r.status_code}" + assert r.json()["value"] == items[key], f"wrong value returned: {r.json()}" return True, "ok"