tests: add storage nodes restart to payment tests (#836)

neofs-testlib/neofs_testlib/env/env.py

@@ -823,6 +823,7 @@ def start(self, fresh=True):
     def stop(self):
         logger.info(f"Stopping Storage Node:{self}")
         self.process.terminate()
+        self.process.wait()
 
     @allure.step("Kill storage node")
     def kill(self):

pytest_tests/lib/helpers/node_management.py

@@ -43,7 +43,7 @@ def start_storage_nodes(nodes: list[StorageNode]) -> None:
     """
     start_threads = []
     for node in nodes:
-        start_threads.append(threading.Thread(target=node._launch_process))
+        start_threads.append(threading.Thread(target=node.start, kwargs={"fresh": False}))
     for t in start_threads:
         t.start()
     for t in start_threads:

pytest_tests/tests/payment/test_container_payments.py

@@ -9,6 +9,7 @@
 from helpers.container import create_container
 from helpers.file_helper import generate_file
 from helpers.neofs_verbs import put_object
+from helpers.node_management import restart_storage_nodes
 from helpers.wallet_helpers import get_neofs_balance, get_wallet_balance
 from neofs_testlib.env.env import NeoFSEnv, NodeWallet
 from neofs_testlib.utils import wallet as wallet_utils
@@ -107,6 +108,9 @@ def test_container_payments(
                 post_data=f"MaxObjectSize={MAX_OBJECT_SIZE} ContainerFee={CONTAINER_FEE} BasicIncomeRate={STORAGE_FEE} EpochDuration={EPOCH_DURATION}",
             )
 
+            # Temporary workaround for a problem with propagading MaxObjectSize between storage nodes
+            restart_storage_nodes(neofs_env.storage_nodes)
+
             objects_count = int(GB / MAX_OBJECT_SIZE) * objects_count_multiplier
 
         with allure.step("Create container and validate that a user was charged with the required amount of GAS"):