diff --git a/tests/sync_auto_random_v2_test.py b/tests/sync_auto_random_v2_test.py new file mode 100644 index 0000000..6411177 --- /dev/null +++ b/tests/sync_auto_random_v2_test.py @@ -0,0 +1,36 @@ +#!/usr/bin/env python3 + +from test_framework.test_framework import TestFramework +from utility.utils import wait_until + +class AutoRandomSyncV2Test(TestFramework): + def setup_params(self): + self.num_nodes = 4 + + # Enable random auto sync v2 + for i in range(self.num_nodes): + self.zgs_node_configs[i] = { + "sync": { + "auto_sync_enabled": True, + "max_sequential_workers": 0, + "max_random_workers": 3, + "neighbors_only": True, + } + } + + def run_test(self): + # Submit and upload files on node 0 + data_root_1 = self.__upload_file__(0, 256 * 1024) + data_root_2 = self.__upload_file__(0, 256 * 1024) + + # Files should be available on other nodes via auto sync + for i in range(1, self.num_nodes): + wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_1) is not None) + wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_1)["finalized"]) + wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_2) is not None) + wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_2)["finalized"]) + + assert 1 > 2 + +if __name__ == "__main__": + AutoRandomSyncV2Test().main()