diff --git a/modules/ducktests/tests/ignitetest/tests/rebalance/persistent_test.py b/modules/ducktests/tests/ignitetest/tests/rebalance/persistent_test.py index 3f47913928621..465288c8c1637 100644 --- a/modules/ducktests/tests/ignitetest/tests/rebalance/persistent_test.py +++ b/modules/ducktests/tests/ignitetest/tests/rebalance/persistent_test.py @@ -70,15 +70,17 @@ def test_node_join(self, ignite_version, backups, cache_count, entry_count, entr await_and_check_rebalance(new_node) - control_utility.deactivate() - nodes = ignites.nodes.copy() nodes.append(new_node.nodes[0]) + result = get_result(new_node.nodes, preload_time, cache_count, entry_count, entry_size) + + control_utility.deactivate() + self.logger.debug(f'DB size after rebalance: {get_database_size_mb(nodes, ignites.database_dir)}') - return get_result(new_node.nodes, preload_time, cache_count, entry_count, entry_size) + return result # pylint: disable=too-many-arguments, too-many-locals @cluster(num_nodes=NUM_NODES) @@ -118,11 +120,13 @@ def test_node_left(self, ignite_version, backups, cache_count, entry_count, entr await_and_check_rebalance(ignites) + result = get_result(ignites.nodes[:-1], preload_time, cache_count, entry_count, entry_size) + control_utility.deactivate() self.logger.debug(f'DB size after rebalance: {get_database_size_mb(ignites.nodes, ignites.database_dir)}') - return get_result(ignites.nodes[:-1], preload_time, cache_count, entry_count, entry_size) + return result @cluster(num_nodes=NUM_NODES) @ignite_versions(str(DEV_BRANCH), str(LATEST)) @@ -186,11 +190,13 @@ def node_join_historical_test(self, ignite_version, backups, cache_count, entry_ await_and_check_rebalance(ignites, rebalance_nodes, False) + result = get_result(rebalance_nodes, preload_time, cache_count, entry_count, entry_size) + control_utility.deactivate() self.logger.debug(f'DB size after rebalance: {get_database_size_mb(ignites.nodes, ignites.database_dir)}') - return get_result(rebalance_nodes, preload_time, cache_count, entry_count, entry_size) + return result def await_and_check_rebalance(service: IgniteService, rebalance_nodes: list = None, is_full: bool = True):