Skip to content
Snippets Groups Projects
Commit f891ff61 authored by pascal.mouquet_ird.fr's avatar pascal.mouquet_ird.fr
Browse files

comment old functions

parent 53e570b2
No related branches found
No related tags found
No related merge requests found
Pipeline #24 canceled
......@@ -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])
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment