diff --git a/pytest_tests/testsuites/failovers/test_failover_storage.py b/pytest_tests/testsuites/failovers/test_failover_storage.py index 27fdafdb..bff58e96 100644 --- a/pytest_tests/testsuites/failovers/test_failover_storage.py +++ b/pytest_tests/testsuites/failovers/test_failover_storage.py @@ -136,66 +136,6 @@ class TestFailoverStorage(ClusterTestBase): ) assert get_file_hash(source_file_path) == get_file_hash(got_file_path) - @allure.title("Panic reboot nodes (sequenced_reboots={sequence})") - @pytest.mark.parametrize("sequence", [True, False]) - @pytest.mark.failover_panic - def test_panic_storage_node_host( - self, - default_wallet, - require_multiple_hosts, - sequence: bool, - simple_object_size: ObjectSize, - cluster_state_controller: ClusterStateController, - ): - wallet = default_wallet - placement_rule = "REP 2 IN X CBF 2 SELECT 2 FROM * AS X" - source_file_path = generate_file(simple_object_size.value) - cid = create_container( - wallet, - shell=self.shell, - endpoint=self.cluster.default_rpc_endpoint, - rule=placement_rule, - basic_acl=PUBLIC_ACL, - ) - oid = put_object_to_random_node(wallet, source_file_path, cid, shell=self.shell, cluster=self.cluster) - - nodes_with_object = wait_object_replication(cid, oid, 2, shell=self.shell, nodes=self.cluster.storage_nodes) - allure.attach( - "\n".join([str(node) for node in nodes_with_object]), - "Current nodes with object", - allure.attachment_type.TEXT, - ) - - new_nodes: list[StorageNode] = [] - with allure.step(f"Hard reboot hosts via magic SysRq option"): - for storage_node in nodes_with_object: - cluster_state_controller.panic_reboot_host(self.cluster.node(storage_node)) - if sequence: - new_nodes = wait_object_replication( - cid, - oid, - 2, - shell=self.shell, - nodes=self.cluster.storage_nodes, - ) - - allure.attach( - "\n".join([str(new_node) for new_node in new_nodes]), - f"Nodes with object after {storage_node} fail", - allure.attachment_type.TEXT, - ) - - if not sequence: - new_nodes = wait_object_replication(cid, oid, 2, shell=self.shell, nodes=self.cluster.storage_nodes) - allure.attach( - "\n".join([str(new_node) for new_node in new_nodes]), - "Nodes with object after nodes fail", - allure.attachment_type.TEXT, - ) - - got_file_path = get_object(wallet, cid, oid, shell=self.shell, endpoint=new_nodes[0].get_rpc_endpoint()) - assert get_file_hash(source_file_path) == get_file_hash(got_file_path) - @allure.title("Do not ignore unhealthy tree endpoints (s3_client={s3_client})") def test_unhealthy_tree( self,