Format code using black

pytest_tests/helpers/aws_cli_client.py

@@ -21,7 +21,7 @@ class AwsCliClient:
 
     def __init__(self, s3gate_endpoint) -> None:
         self.s3gate_endpoint = s3gate_endpoint
-        os.environ['AWS_EC2_METADATA_DISABLED'] = 'true'
+        os.environ["AWS_EC2_METADATA_DISABLED"] = "true"
 
     def create_bucket(
         self,

pytest_tests/helpers/file_helper.py

@@ -99,7 +99,9 @@ def concat_files(file_paths: list, resulting_file_path: Optional[str] = None) ->
         Path to the resulting file.
     """
     if not resulting_file_path:
-        resulting_file_path = os.path.join(os.getcwd(), ASSETS_DIR, TEST_FILES_DIR, str(uuid.uuid4()))
+        resulting_file_path = os.path.join(
+            os.getcwd(), ASSETS_DIR, TEST_FILES_DIR, str(uuid.uuid4())
+        )
     with open(resulting_file_path, "wb") as f:
         for file in file_paths:
             with open(file, "rb") as part_file:

pytest_tests/helpers/grpc_responses.py

@@ -34,7 +34,10 @@
 EACL_TIMED_OUT = "eACL setting: await timeout expired"
 EACL_TABLE_IS_NOT_SET = "extended ACL table is not set for this container"
 EACL_NOT_FOUND = "code = 3073.*message = eACL not found"
-EACL_PROHIBITED_TO_MODIFY_SYSTEM_ACCESS = "table validation: it is prohibited to modify system access"
+EACL_PROHIBITED_TO_MODIFY_SYSTEM_ACCESS = (
+    "table validation: it is prohibited to modify system access"
+)
+
 
 def error_matches_status(error: Exception, status_pattern: str) -> bool:
     """

pytest_tests/steps/session_token.py

@@ -237,7 +237,7 @@ def create_session_token(
     wallet_password: str,
     rpc_endpoint: str,
     lifetime: Optional[int] = None,
-    expire_at: Optional[int] = None
+    expire_at: Optional[int] = None,
 ) -> str:
     """
     Create session token for an object.
@@ -259,7 +259,7 @@ def create_session_token(
         wallet_password=wallet_password,
         out=session_token,
         lifetime=lifetime,
-        expire_at=expire_at
+        expire_at=expire_at,
     )
     return session_token
 

pytest_tests/testsuites/acl/storage_group/test_storagegroup.py

@@ -47,7 +47,9 @@ class TestStorageGroup(ClusterTestBase):
     @pytest.fixture(autouse=True)
     def prepare_two_wallets(self, default_wallet):
         self.main_wallet = default_wallet
-        self.other_wallet = os.path.join(os.getcwd(), ASSETS_DIR, TEST_FILES_DIR, f"{str(uuid.uuid4())}.json")
+        self.other_wallet = os.path.join(
+            os.getcwd(), ASSETS_DIR, TEST_FILES_DIR, f"{str(uuid.uuid4())}.json"
+        )
         init_wallet(self.other_wallet, WALLET_PASS)
         if not FREE_STORAGE:
             main_chain = self.cluster.main_chain_nodes[0]

pytest_tests/testsuites/acl/test_acl.py

@@ -3,8 +3,15 @@
 
 from testsuites.acl.conftest import Wallets
 from cluster_test_base import ClusterTestBase
-from object_access import can_put_object, can_get_object, can_get_head_object, can_search_object, \
-    can_get_range_of_object, can_get_range_hash_of_object, can_delete_object
+from object_access import (
+    can_put_object,
+    can_get_object,
+    can_get_head_object,
+    can_search_object,
+    can_get_range_of_object,
+    can_get_range_hash_of_object,
+    can_delete_object,
+)
 from python_keywords.acl import EACLRole
 from python_keywords.container import create_container
 from python_keywords.container_access import (
@@ -184,7 +191,9 @@ def test_basic_acl_readonly(self, wallets, client_shell, read_only_container, fi
             )
 
     @allure.title("Test basic ACL IR and STORAGE rules compliance")
-    def test_basic_acl_ir_storage_rules_compliance(self, wallets: Wallets, public_container: str, file_path: str):
+    def test_basic_acl_ir_storage_rules_compliance(
+        self, wallets: Wallets, public_container: str, file_path: str
+    ):
         """
         Test basic ACL IR and STORAGE rules compliance.
 
@@ -311,7 +320,9 @@ def test_basic_acl_ir_storage_rules_compliance(self, wallets: Wallets, public_co
                     endpoint=endpoint,
                     wallet_config=ir_wallet.config_path,
                 )
-            with allure.step("STORAGE node should NOT be able to GET range of object from container"):
+            with allure.step(
+                "STORAGE node should NOT be able to GET range of object from container"
+            ):
                 assert not can_get_range_of_object(
                     wallet=storage_wallet.wallet_path,
                     cid=cid,
@@ -330,7 +341,9 @@ def test_basic_acl_ir_storage_rules_compliance(self, wallets: Wallets, public_co
                     endpoint=endpoint,
                     wallet_config=ir_wallet.config_path,
                 )
-            with allure.step("STORAGE node should be able to GET range hash of object from container"):
+            with allure.step(
+                "STORAGE node should be able to GET range hash of object from container"
+            ):
                 assert can_get_range_hash_of_object(
                     wallet=storage_wallet.wallet_path,
                     cid=cid,
@@ -358,4 +371,3 @@ def test_basic_acl_ir_storage_rules_compliance(self, wallets: Wallets, public_co
                     endpoint=endpoint,
                     wallet_config=storage_wallet.config_path,
                 )
-

pytest_tests/testsuites/acl/test_eacl.py

@@ -11,7 +11,8 @@
     EACLRule,
     create_eacl,
     set_eacl,
-    wait_for_cache_expired, get_eacl,
+    wait_for_cache_expired,
+    get_eacl,
 )
 from python_keywords.container import create_container
 from python_keywords.container_access import (
@@ -302,8 +303,12 @@ def test_deprecated_change_system_eacl(self, wallets, eacl_container_with_object
 
     @pytest.mark.trusted_party_proved
     @pytest.mark.system_eacl
-    @allure.title("Test case for verifying the impossible to change system extended ACL if eACL already set")
-    def test_deprecated_change_system_eacl_if_eacl_already_set(self, wallets, eacl_container_with_objects):
+    @allure.title(
+        "Test case for verifying the impossible to change system extended ACL if eACL already set"
+    )
+    def test_deprecated_change_system_eacl_if_eacl_already_set(
+        self, wallets, eacl_container_with_objects
+    ):
         user_wallet = wallets.get_wallet()
         cid, object_oids, file_path = eacl_container_with_objects
         endpoint = self.cluster.default_rpc_endpoint
@@ -489,7 +494,7 @@ def test_only_owner_can_set_eacl(
         self,
         wallets: Wallets,
         eacl_full_placement_container_with_object: tuple[str, str, str],
-        not_owner_wallet: str
+        not_owner_wallet: str,
     ):
         cid, oid, file_path = eacl_full_placement_container_with_object
 

pytest_tests/testsuites/conftest.py

@@ -66,6 +66,7 @@ def pytest_runtest_makereport(item, call):
     # be "setup", "call", "teardown"
     item.stash.setdefault(phase_report_key, {})[rep.when] = rep
 
+
 def pytest_collection_modifyitems(items):
     # Make network tests last based on @pytest.mark.node_mgmt
     def priority(item: pytest.Item) -> int:
@@ -167,7 +168,7 @@ def temp_directory() -> str:
 
 
 @pytest.fixture(scope="module", autouse=True)
-@allure.title(f'Prepare test files directories')
+@allure.title(f"Prepare test files directories")
 def artifacts_directory(temp_directory: str) -> None:
     dirs = [TEST_FILES_DIR, TEST_OBJECTS_DIR]
     for dir_name in dirs:
@@ -185,7 +186,7 @@ def artifacts_directory(temp_directory: str) -> None:
 @pytest.fixture(scope="session", autouse=True)
 @allure.title("Collect full logs")
 def collect_full_tests_logs(temp_directory, hosting: Hosting):
-    test_name = 'full_logs'
+    test_name = "full_logs"
     start_time = datetime.utcnow()
     yield
     end_time = datetime.utcnow()
@@ -199,15 +200,15 @@ def collect_full_tests_logs(temp_directory, hosting: Hosting):
 def collect_test_logs(request, temp_directory, hosting: Hosting):
     test_name = request.node.nodeid.translate(str.maketrans(":[]/", "____"))
     hash_suffix = hashlib.md5(test_name.encode()).hexdigest()
-    file_name = (test_name[:200] + '_' + hash_suffix)  # limit total length to 255
+    file_name = test_name[:200] + "_" + hash_suffix  # limit total length to 255
     logs_dir = os.path.join(temp_directory, "logs")
-    with allure.step(f'Start collecting logs for {file_name}'):
+    with allure.step(f"Start collecting logs for {file_name}"):
         start_time = datetime.utcnow()
     yield
     # https://docs.pytest.org/en/latest/example/simple.html#making-test-result-information-available-in-fixtures
     report = request.node.stash[phase_report_key]
     if report["setup"].failed or ("call" in report and report["call"].failed):
-        with allure.step(f'Stop collecting logs for {file_name}, logs path: {logs_dir} '):
+        with allure.step(f"Stop collecting logs for {file_name}, logs path: {logs_dir} "):
             end_time = datetime.utcnow()
             store_logs(hosting, logs_dir, file_name, start_time, end_time)
 
@@ -219,13 +220,13 @@ def netinfo(request, cluster: Cluster, client_shell: Shell, default_wallet: str)
     report = request.node.stash[phase_report_key]
     if report["setup"].failed or ("call" in report and report["call"].failed):
         for node in cluster.storage_nodes:
-            with allure.step(f'Checking netinfo for node {node}'):
+            with allure.step(f"Checking netinfo for node {node}"):
                 net_info = get_netmap_netinfo(
                     wallet=default_wallet,
                     endpoint=node.get_rpc_endpoint(),
                     shell=client_shell,
                 )
-            logger.info(f'Netinfo from {node}:\n{net_info}')
+            logger.info(f"Netinfo from {node}:\n{net_info}")
 
 
 @pytest.fixture(scope="session", autouse=True)
@@ -309,7 +310,7 @@ def background_grpc_load(client_shell: Shell, hosting: Hosting):
 @pytest.fixture(scope="function")
 @allure.title("Prepare not owner wallet and deposit")
 def not_owner_wallet(client_shell: Shell, temp_directory: str, cluster: Cluster) -> str:
-    wallet_path = create_wallet(client_shell, temp_directory, cluster, 'not_owner_wallet')
+    wallet_path = create_wallet(client_shell, temp_directory, cluster, "not_owner_wallet")
     yield wallet_path
     os.remove(wallet_path)
 
@@ -319,6 +320,7 @@ def not_owner_wallet(client_shell: Shell, temp_directory: str, cluster: Cluster)
 def default_wallet(client_shell: Shell, temp_directory: str, cluster: Cluster):
     return create_wallet(client_shell, temp_directory, cluster)
 
+
 @allure.title("Check logs for OOM and PANIC entries in {logs_dir}")
 def check_logs(logs_dir: str):
     problem_pattern = r"\Wpanic\W|\Woom\W|\Wtoo many open files\W"
@@ -341,7 +343,9 @@ def check_logs(logs_dir: str):
         raise pytest.fail(f"System logs {', '.join(logs_with_problem)} contain critical errors")
 
 
-def store_logs(hosting: Hosting, logs_dir: str, file_name: str, start_time: datetime, end_time: datetime) -> None:
+def store_logs(
+    hosting: Hosting, logs_dir: str, file_name: str, start_time: datetime, end_time: datetime
+) -> None:
     os.makedirs(logs_dir, exist_ok=True)
     dump_logs(hosting, logs_dir, start_time, end_time)
     attach_logs(logs_dir, os.path.join(os.getcwd(), ASSETS_DIR, file_name))
@@ -363,7 +367,7 @@ def attach_logs(logs_dir: str, test_name: str) -> None:
     # Zip all files and attach to Allure because it is more convenient to download a single
     # zip with all logs rather than mess with individual logs files per service or node
     logs_zip_file_path = shutil.make_archive(test_name, "zip", logs_dir)
-    allure.attach.file(logs_zip_file_path, name=f'{test_name}.zip', extension="zip")
+    allure.attach.file(logs_zip_file_path, name=f"{test_name}.zip", extension="zip")
 
 
 def create_dir(dir_path: str) -> None:
@@ -378,11 +382,13 @@ def remove_dir(dir_path: str) -> None:
 
 
 @allure.title("Prepare wallet and deposit")
-def create_wallet(client_shell: Shell, temp_directory: str, cluster: Cluster, name: Optional[str] = None) -> str:
+def create_wallet(
+    client_shell: Shell, temp_directory: str, cluster: Cluster, name: Optional[str] = None
+) -> str:
     if name is None:
-        wallet_name = f'{str(uuid.uuid4())}.json'
+        wallet_name = f"{str(uuid.uuid4())}.json"
     else:
-        wallet_name = f'{name}.json'
+        wallet_name = f"{name}.json"
 
     wallet_path = os.path.join(os.getcwd(), ASSETS_DIR, wallet_name)
     init_wallet(wallet_path, WALLET_PASS)

pytest_tests/testsuites/container/test_container.py

@@ -91,9 +91,7 @@ def test_container_creation(self, default_wallet, name):
     @pytest.mark.trusted_party_proved
     @allure.title("Not owner and not trusted party can NOT delete container")
     def test_only_owner_can_delete_container(
-            self,
-            not_owner_wallet: WalletFile,
-            default_wallet: str
+        self, not_owner_wallet: WalletFile, default_wallet: str
     ):
         cid = create_container(
             wallet=default_wallet,