Delete wait replication steps for tests #56
1 changed files with 0 additions and 11 deletions
|
@ -144,8 +144,6 @@ class TestFailoverServer(ClusterTestBase):
|
||||||
node_to_stop: ClusterNode,
|
node_to_stop: ClusterNode,
|
||||||
cluster_state_controller: ClusterStateController,
|
cluster_state_controller: ClusterStateController,
|
||||||
):
|
):
|
||||||
with allure.step("Checking that the objects are loader according to the policy"):
|
|
||||||
self.check_objects_replication(storage_objects, self.cluster.storage_nodes)
|
|
||||||
|
|
||||||
with allure.step(f"Remove {node_to_stop} from the list of nodes"):
|
with allure.step(f"Remove {node_to_stop} from the list of nodes"):
|
||||||
alive_nodes = list(set(self.cluster.cluster_nodes) - {node_to_stop})
|
alive_nodes = list(set(self.cluster.cluster_nodes) - {node_to_stop})
|
||||||
|
@ -163,9 +161,6 @@ class TestFailoverServer(ClusterTestBase):
|
||||||
with allure.step(f"Check if the node {node_to_stop.storage_node} has stopped"):
|
with allure.step(f"Check if the node {node_to_stop.storage_node} has stopped"):
|
||||||
wait_for_host_offline(self.shell, node_to_stop.storage_node)
|
wait_for_host_offline(self.shell, node_to_stop.storage_node)
|
||||||
|
|
||||||
with allure.step("Wait for objects replication"):
|
|
||||||
self.check_objects_replication(storage_objects, storage_nodes)
|
|
||||||
|
|
||||||
with allure.step("Verify that there are no corrupted objects"):
|
with allure.step("Verify that there are no corrupted objects"):
|
||||||
corrupted_objects_list = self.get_corrupted_objects_list(storage_nodes, storage_objects)
|
corrupted_objects_list = self.get_corrupted_objects_list(storage_nodes, storage_objects)
|
||||||
|
|
||||||
|
@ -207,9 +202,6 @@ class TestFailoverServer(ClusterTestBase):
|
||||||
node_to_stop: ClusterNode,
|
node_to_stop: ClusterNode,
|
||||||
cluster_state_controller: ClusterStateController,
|
cluster_state_controller: ClusterStateController,
|
||||||
):
|
):
|
||||||
with allure.step("Checking that the objects are loader according to the policy"):
|
|
||||||
self.check_objects_replication(storage_objects, self.cluster.storage_nodes)
|
|
||||||
|
|
||||||
with allure.step(f"Remove {node_to_stop} from the list of nodes"):
|
with allure.step(f"Remove {node_to_stop} from the list of nodes"):
|
||||||
storage_nodes = list(set(self.cluster.storage_nodes) - {node_to_stop.storage_node})
|
storage_nodes = list(set(self.cluster.storage_nodes) - {node_to_stop.storage_node})
|
||||||
|
|
||||||
|
@ -224,9 +216,6 @@ class TestFailoverServer(ClusterTestBase):
|
||||||
with allure.step(f"Check if the node {node_to_stop} has stopped"):
|
with allure.step(f"Check if the node {node_to_stop} has stopped"):
|
||||||
wait_for_host_offline(self.shell, node_to_stop.storage_node)
|
wait_for_host_offline(self.shell, node_to_stop.storage_node)
|
||||||
|
|
||||||
with allure.step("Wait for objects replication"):
|
|
||||||
self.check_objects_replication(storage_objects, storage_nodes)
|
|
||||||
|
|
||||||
with allure.step("Verify that there are no corrupted objects"):
|
with allure.step("Verify that there are no corrupted objects"):
|
||||||
corrupted_objects_list = self.get_corrupted_objects_list(storage_nodes, storage_objects)
|
corrupted_objects_list = self.get_corrupted_objects_list(storage_nodes, storage_objects)
|
||||||
assert not corrupted_objects_list
|
assert not corrupted_objects_list
|
||||||
|
|
Loading…
Reference in a new issue