Small fix using function search container #185
1 changed files with 8 additions and 12 deletions
|
@ -51,12 +51,10 @@ class TestS3GatePolicy(ClusterTestBase):
|
||||||
assert bucket_loc_2 == "rep-3"
|
assert bucket_loc_2 == "rep-3"
|
||||||
|
|
||||||
with reporter.step("Check object policy"):
|
with reporter.step("Check object policy"):
|
||||||
cid_1 = search_container_by_name(
|
for cluster_node in self.cluster.cluster_nodes:
|
||||||
default_wallet,
|
cid_1 = search_container_by_name(name=bucket_1, node=cluster_node)
|
||||||
bucket_1,
|
if cid_1:
|
||||||
shell=self.shell,
|
break
|
||||||
endpoint=self.cluster.default_rpc_endpoint,
|
|
||||||
)
|
|
||||||
copies_1 = get_simple_object_copies(
|
copies_1 = get_simple_object_copies(
|
||||||
wallet=default_wallet,
|
wallet=default_wallet,
|
||||||
cid=cid_1,
|
cid=cid_1,
|
||||||
|
@ -65,12 +63,10 @@ class TestS3GatePolicy(ClusterTestBase):
|
||||||
nodes=self.cluster.storage_nodes,
|
nodes=self.cluster.storage_nodes,
|
||||||
)
|
)
|
||||||
assert copies_1 == 1
|
assert copies_1 == 1
|
||||||
cid_2 = search_container_by_name(
|
for cluster_node in self.cluster.cluster_nodes:
|
||||||
default_wallet,
|
cid_2 = search_container_by_name(name=bucket_1, node=cluster_node)
|
||||||
bucket_2,
|
if cid_2:
|
||||||
shell=self.shell,
|
break
|
||||||
endpoint=self.cluster.default_rpc_endpoint,
|
|
||||||
)
|
|
||||||
copies_2 = get_simple_object_copies(
|
copies_2 = get_simple_object_copies(
|
||||||
wallet=default_wallet,
|
wallet=default_wallet,
|
||||||
cid=cid_2,
|
cid=cid_2,
|
||||||
|
|
Loading…
Reference in a new issue