diff --git a/pytest_tests/testsuites/metrics/test_grpc_metrics.py b/pytest_tests/testsuites/metrics/test_grpc_metrics.py index cc7780f2..aa89b2d5 100644 --- a/pytest_tests/testsuites/metrics/test_grpc_metrics.py +++ b/pytest_tests/testsuites/metrics/test_grpc_metrics.py @@ -31,6 +31,7 @@ class TestGRPCMetrics(ClusterTestBase): @allure.title("GRPC metrics container operations") def test_grpc_metrics_container_operations(self, default_wallet: WalletInfo, cluster: Cluster): + operations_count = 10 placement_policy = "REP 2 IN X CBF 1 SELECT 4 FROM * AS X" with reporter.step("Select random node"): @@ -56,12 +57,14 @@ class TestGRPCMetrics(ClusterTestBase): metrics_counter_get = get_metrics_value(node, command="grpc_server_handled_total", service="ContainerService", method="Get") with reporter.step(f"Get container"): - get_container(default_wallet, cid, self.shell, node.storage_node.get_rpc_endpoint()) + for _ in range(operations_count): + get_container(default_wallet, cid, self.shell, node.storage_node.get_rpc_endpoint()) with reporter.step(f"Check gRPC metrics method=Get, 'the counter should increase by 1'"): - metrics_counter_get += 1 + metrics_counter_get += operations_count check_metrics_counter( [node], + operator=">=", counter_exp=metrics_counter_get, command="grpc_server_handled_total", service="ContainerService", @@ -72,12 +75,14 @@ class TestGRPCMetrics(ClusterTestBase): metrics_counter_list = get_metrics_value(node, command="grpc_server_handled_total", service="ContainerService", method="List") with reporter.step(f"Get container list"): - list_containers(default_wallet, self.shell, node.storage_node.get_rpc_endpoint()) + for _ in range(operations_count): + list_containers(default_wallet, self.shell, node.storage_node.get_rpc_endpoint()) with reporter.step(f"Check gRPC metrics method=List, 'the counter should increase by 1'"): - metrics_counter_list += 1 + metrics_counter_list += operations_count check_metrics_counter( [node], + operator=">=", counter_exp=metrics_counter_list, command="grpc_server_handled_total", service="ContainerService", @@ -88,6 +93,7 @@ class TestGRPCMetrics(ClusterTestBase): def test_grpc_metrics_object_operations( self, simple_object_size: ObjectSize, default_wallet: WalletInfo, cluster: Cluster, container: str, disable_policer ): + operations_count = 10 file_path = generate_file(simple_object_size.value) with reporter.step("Select random node"): @@ -97,12 +103,14 @@ class TestGRPCMetrics(ClusterTestBase): metrics_counter_put = get_metrics_value(node, command="grpc_server_handled_total", service="ObjectService", method="Put") with reporter.step("Put object to selected node"): - oid = put_object(default_wallet, file_path, container, self.shell, node.storage_node.get_rpc_endpoint()) + for _ in range(operations_count): + oid = put_object(default_wallet, file_path, container, self.shell, node.storage_node.get_rpc_endpoint()) - with reporter.step(f"Check gRPC metrics method 'Put', 'the counter should increase by 1'"): - metrics_counter_put += 1 + with reporter.step(f"Check gRPC metrics method 'Put', 'the counter should increase by {operations_count}'"): + metrics_counter_put += operations_count check_metrics_counter( [node], + operator=">=", counter_exp=metrics_counter_put, command="grpc_server_handled_total", service="ObjectService", @@ -113,12 +121,14 @@ class TestGRPCMetrics(ClusterTestBase): metrics_counter_get = get_metrics_value(node, command="grpc_server_handled_total", service="ObjectService", method="Get") with reporter.step(f"Get object"): - get_object(default_wallet, container, oid, self.shell, node.storage_node.get_rpc_endpoint()) + for _ in range(operations_count): + get_object(default_wallet, container, oid, self.shell, node.storage_node.get_rpc_endpoint()) - with reporter.step(f"Check gRPC metrics method=Get, 'the counter should increase by 1'"): - metrics_counter_get += 1 + with reporter.step(f"Check gRPC metrics method=Get, 'the counter should increase by {operations_count}'"): + metrics_counter_get += operations_count check_metrics_counter( [node], + operator=">=", counter_exp=metrics_counter_get, command="grpc_server_handled_total", service="ObjectService", @@ -129,12 +139,14 @@ class TestGRPCMetrics(ClusterTestBase): metrics_counter_search = get_metrics_value(node, command="grpc_server_handled_total", service="ObjectService", method="Search") with reporter.step(f"Search object"): - search_object(default_wallet, container, self.shell, node.storage_node.get_rpc_endpoint()) + for _ in range(operations_count): + search_object(default_wallet, container, self.shell, node.storage_node.get_rpc_endpoint()) - with reporter.step(f"Check gRPC metrics method=Search, 'the counter should increase by 1'"): - metrics_counter_search += 1 + with reporter.step(f"Check gRPC metrics method=Search, 'the counter should increase by {operations_count}'"): + metrics_counter_search += operations_count check_metrics_counter( [node], + operator=">=", counter_exp=metrics_counter_search, command="grpc_server_handled_total", service="ObjectService", @@ -145,12 +157,14 @@ class TestGRPCMetrics(ClusterTestBase): metrics_counter_head = get_metrics_value(node, command="grpc_server_handled_total", service="ObjectService", method="Head") with reporter.step(f"Head object"): - head_object(default_wallet, container, oid, self.shell, node.storage_node.get_rpc_endpoint()) + for _ in range(operations_count): + head_object(default_wallet, container, oid, self.shell, node.storage_node.get_rpc_endpoint()) - with reporter.step(f"Check gRPC metrics method=Head, 'the counter should increase by 1'"): - metrics_counter_head += 1 + with reporter.step(f"Check gRPC metrics method=Head, 'the counter should increase by {operations_count}'"): + metrics_counter_head += operations_count check_metrics_counter( [node], + operator=">=", counter_exp=metrics_counter_head, command="grpc_server_handled_total", service="ObjectService",