diff --git a/core/trainers/framework/dataset.py b/core/trainers/framework/dataset.py index 8a01476c548a7017cbcf5803d23901e6d1a519e7..8059eeb09a482671b8329fb88f5b52cfd64f163b 100644 --- a/core/trainers/framework/dataset.py +++ b/core/trainers/framework/dataset.py @@ -89,24 +89,6 @@ class QueueDataset(DatasetBase): else: return self._get_dataset(dataset_name, context) - def check_filelist(self, file_list, train_data_path): - for root, dirs, files in os.walk(train_data_path): - files = [f for f in files if not f[0] == '.'] - dirs[:] = [d for d in dirs if not d[0] == '.'] - if (files == None and dirs == None): - return None - else: - # use files and dirs - for file_name in files: - file_list.append(os.path.join(train_data_path, file_name)) - print(os.path.join(train_data_path, file_name)) - for dirs_name in dirs: - dir_root.append(os.path.join(train_data_path, dirs_name)) - check_filelist(file_list, os.path.join( - train_data_path, dirs_name)) - print(os.path.join(train_data_path, dirs_name)) - return file_list - def _get_dataset(self, dataset_name, context): name = "dataset." + dataset_name + "." reader_class = envs.get_global_env(name + "data_converter") @@ -137,13 +119,10 @@ class QueueDataset(DatasetBase): dataset.set_pipe_command(pipe_cmd) train_data_path = envs.get_global_env(name + "data_path") - # file_list = [ - # os.path.join(train_data_path, x) - # for x in os.listdir(train_data_path) - # ] - file_list=[] - file_list = self.check_filelist(file_list,train_data_path) - + file_list = [ + os.path.join(train_data_path, x) + for x in os.listdir(train_data_path) + ] if context["engine"] == EngineMode.LOCAL_CLUSTER: file_list = split_files(file_list, context["fleet"].worker_index(), context["fleet"].worker_num()) diff --git a/core/utils/dataloader_instance.py b/core/utils/dataloader_instance.py index b5e86baf6ea30b9b2d73d13b55d2dc2c67b849fc..2461473aa79a51133db8aa319f4ee7d45981d815 100755 --- a/core/utils/dataloader_instance.py +++ b/core/utils/dataloader_instance.py @@ -38,27 +38,7 @@ def dataloader_by_name(readerclass, assert package_base is not None data_path = os.path.join(package_base, data_path.split("::")[1]) - def check_filelist(file_list, train_data_path): - for root, dirs, files in os.walk(train_data_path): - files = [f for f in files if not f[0] == '.'] - dirs[:] = [d for d in dirs if not d[0] == '.'] - if (files == None and dirs == None): - return None - else: - # use files and dirs - for file_name in files: - file_list.append(os.path.join(train_data_path, file_name)) - print(os.path.join(train_data_path, file_name)) - for dirs_name in dirs: - dir_root.append(os.path.join(train_data_path, dirs_name)) - check_filelist(file_list, os.path.join( - train_data_path, dirs_name)) - print(os.path.join(train_data_path, dirs_name)) - return file_list - - #files = [str(data_path) + "/%s" % x for x in os.listdir(data_path)] - files = [] - files = check_filelist(files, data_path) + files = [str(data_path) + "/%s" % x for x in os.listdir(data_path)] if context["engine"] == EngineMode.LOCAL_CLUSTER: files = split_files(files, context["fleet"].worker_index(), context["fleet"].worker_num()) @@ -100,27 +80,7 @@ def slotdataloader_by_name(readerclass, dataset_name, yaml_file, context): assert package_base is not None data_path = os.path.join(package_base, data_path.split("::")[1]) - def check_filelist(file_list, train_data_path): - for root, dirs, files in os.walk(train_data_path): - files = [f for f in files if not f[0] == '.'] - dirs[:] = [d for d in dirs if not d[0] == '.'] - if (files == None and dirs == None): - return None - else: - # use files and dirs - for file_name in files: - file_list.append(os.path.join(train_data_path, file_name)) - print(os.path.join(train_data_path, file_name)) - for dirs_name in dirs: - dir_root.append(os.path.join(train_data_path, dirs_name)) - check_filelist(file_list, os.path.join( - train_data_path, dirs_name)) - print(os.path.join(train_data_path, dirs_name)) - return file_list - - #files = [str(data_path) + "/%s" % x for x in os.listdir(data_path)] - files = [] - files = check_filelist(files, data_path) + files = [str(data_path) + "/%s" % x for x in os.listdir(data_path)] if context["engine"] == EngineMode.LOCAL_CLUSTER: files = split_files(files, context["fleet"].worker_index(), context["fleet"].worker_num())