Skip to content

Commit

Permalink
123
Browse files Browse the repository at this point in the history
Signed-off-by: Evgeniy Zayats <[email protected]>
  • Loading branch information
Evgeniy Zayats committed Jun 21, 2024
1 parent 4e4dde2 commit 6395c18
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 4 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/run-tests.yml
Original file line number Diff line number Diff line change
Expand Up @@ -223,7 +223,7 @@ jobs:
env:
ALLURE_RESULTS_DIR: ${{ env.ALLURE_RESULTS_DIR }}
run: |
source venv.pytest/bin/activate && pytest --alluredir=${GITHUB_WORKSPACE}/allure-results pytest_tests/tests
source venv.pytest/bin/activate && pytest -k "test_block_storage_node_traffic or test_rpc_reconnection or test_enable_resync_metabase_delete_metadata or test_delete_metadata" --alluredir=${GITHUB_WORKSPACE}/allure-results pytest_tests/tests
working-directory: neofs-testcases

################################################################
Expand Down
12 changes: 9 additions & 3 deletions pytest_tests/tests/failovers/test_failover_network.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@
@pytest.mark.failover_network
@pytest.mark.skipif(sys.platform == "darwin", reason="not supported on macos runners")
class TestFailoverNetwork(NeofsEnvTestBase):
@pytest.fixture(autouse=True)
@allure.step("Restore network")
def restore_network(self):
yield
Expand All @@ -36,9 +35,16 @@ def restore_network(self):
blocked_nodes.remove(node)
if not_empty:
wait_all_storage_nodes_returned(self.neofs_env)

for node in self.neofs_env.storage_nodes:
node.kill()
for node in self.neofs_env.storage_nodes:
node.start(fresh=False)

wait_all_storage_nodes_returned(self.neofs_env)

@allure.title("Block Storage node traffic")
def test_block_storage_node_traffic(self, default_wallet, simple_object_size):
def test_block_storage_node_traffic(self, default_wallet, simple_object_size, restore_network):
"""
Block storage nodes traffic using iptables and wait for replication for objects.
"""
Expand Down Expand Up @@ -106,7 +112,7 @@ def test_block_storage_node_traffic(self, default_wallet, simple_object_size):

@pytest.mark.sanity
@allure.title("RPC reconnection test")
def test_rpc_reconnection(self, default_wallet):
def test_rpc_reconnection(self, default_wallet, restore_network):
"""
When RPC connection fails (and it can), storage node reconnects to some other node and continues to operate.
"""
Expand Down

0 comments on commit 6395c18

Please sign in to comment.