diff --git a/sen2chain/multi_processing.py b/sen2chain/multi_processing.py index 27941477b83c6a6bc3c5f5d9d3fe4f70bf0bde12..a5549d03d9a211087ae55c3db6906fe50d979cd7 100644 --- a/sen2chain/multi_processing.py +++ b/sen2chain/multi_processing.py @@ -39,35 +39,35 @@ def l2a_multiprocessing(process_list, nb_proc=4): pool.join() return True -def multi_cldidx(indice_list, l2a_identifier): - l2a = L2aProduct(l2a_identifier) - l2a.process_cloud_mask_v2() - l2a.process_indices(indice_list, True, True) +#~ def multi_cldidx(indice_list, l2a_identifier): + #~ l2a = L2aProduct(l2a_identifier) + #~ l2a.process_cloud_mask_v2() + #~ l2a.process_indices(indice_list, True, True) -def cldidx_multiprocessing(process_list, indice_list=["NDVI", "NDWIGAO", "NDWIMCF"], nb_proc=4): - """ """ - nb_proc = max(min(len(os.sched_getaffinity(0))-1, nb_proc), 1) - pool = multiprocessing.Pool(nb_proc) - results = [pool.map(partial(multi_cldidx, indice_list), process_list)] - pool.close() - pool.join() - return True +#~ def cldidx_multiprocessing(process_list, indice_list=["NDVI", "NDWIGAO", "NDWIMCF"], nb_proc=4): + #~ """ """ + #~ nb_proc = max(min(len(os.sched_getaffinity(0))-1, nb_proc), 1) + #~ pool = multiprocessing.Pool(nb_proc) + #~ results = [pool.map(partial(multi_cldidx, indice_list), process_list)] + #~ pool.close() + #~ pool.join() + #~ return True -def multi_cld(l2a_identifier): - l2a = L2aProduct(l2a_identifier) - try: - l2a.process_cloud_mask_v2() - except: - pass +#~ def multi_cld(l2a_identifier): + #~ l2a = L2aProduct(l2a_identifier) + #~ try: + #~ l2a.process_cloud_mask_v2() + #~ except: + #~ pass -def cld_multiprocessing(process_list, nb_proc=4): - """ """ - nb_proc = max(min(len(os.sched_getaffinity(0))-1, nb_proc), 1) - pool = multiprocessing.Pool(nb_proc) - results = [pool.map(multi_cld, process_list)] - pool.close() - pool.join() - return True +#~ def cld_multiprocessing(process_list, nb_proc=4): + #~ """ """ + #~ nb_proc = max(min(len(os.sched_getaffinity(0))-1, nb_proc), 1) + #~ pool = multiprocessing.Pool(nb_proc) + #~ results = [pool.map(multi_cld, process_list)] + #~ pool.close() + #~ pool.join() + #~ return True def multi_cld_ver_pro_iter_repro(l2a_ver_pro_iter_repro): l2a = L2aProduct(l2a_ver_pro_iter_repro[0])