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

made get_all in basic_proxy eventually time out

parent 9dd85876
No related branches found
No related tags found
No related merge requests found
...@@ -24,7 +24,7 @@ def basic_proxy_one_client(conductor: ClusterConductor, dir, log: Logger): ...@@ -24,7 +24,7 @@ def basic_proxy_one_client(conductor: ClusterConductor, dir, log: Logger):
node_to_put += 1 node_to_put += 1
node_to_put = node_to_put % 4 node_to_put = node_to_put % 4
r = c.get_all(0, timeout=None) # should get all of shard 1's keys r = c.get_all(0, timeout=120) # should get all of shard 1's keys
assert r.ok, f"expected ok for get, got {r.status_code}" assert r.ok, f"expected ok for get, got {r.status_code}"
items = r.json()["items"] items = r.json()["items"]
keys = items.keys() keys = items.keys()
...@@ -57,7 +57,7 @@ def basic_proxy_many_clients(conductor: ClusterConductor, dir, log: Logger): ...@@ -57,7 +57,7 @@ def basic_proxy_many_clients(conductor: ClusterConductor, dir, log: Logger):
node_to_put += 1 node_to_put += 1
node_to_put = node_to_put % 7 node_to_put = node_to_put % 7
r = c.get_all(0, timeout=None) # should get all of shard 1's keys r = c.get_all(0, timeout=120) # should get all of shard 1's keys
assert r.ok, f"expected ok for get, got {r.status_code}" assert r.ok, f"expected ok for get, got {r.status_code}"
items = r.json()["items"] items = r.json()["items"]
keys = items.keys() keys = items.keys()
......
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