diff --git a/coordinator/EnvSuitPipeline.py b/coordinator/EnvSuitPipeline.py index f790a1032236d1d9cd64576d0917ac52b530c51e..daf5e3a3a90c653b11dd5a2bf6c68378ddc00d4a 100644 --- a/coordinator/EnvSuitPipeline.py +++ b/coordinator/EnvSuitPipeline.py @@ -213,15 +213,15 @@ def run_pipeline(pipeline_config, region, dateString, extracted = False, prevent config['POST_PROCESSING']['PROCESSORS'][p]['TIMEPOINTS_FILE_PATH'] = extraction_temporal_points_file # Clean if extraction is not done - if (extracted == False): - clean(workPath) + # if (extracted == False): + # clean(workPath) # generate_all(sys_config, config) # Extract - if (extracted == False): - run_extraction(config, sys_config) - extracted = True + # if (extracted == False): + # run_extraction(config, sys_config) + # extracted = True logger.info(f"Starting {processor_name} post processor ---------------------------------") run_post_processing(config, sys_config, processor_name) @@ -245,15 +245,15 @@ def run_pipeline(pipeline_config, region, dateString, extracted = False, prevent config['POST_PROCESSING']['PROCESSORS'][p]['PARAMS']['thresholds'] = pipeline_config['PARAMS'][strain]['thresholds'] # Clean if extraction is not done - if (extracted == False): - clean(workPath) + # if (extracted == False): + # clean(workPath) # generate_all(sys_config, config) # Extract - if (extracted == False): - run_extraction(config, sys_config) - extracted = True + # if (extracted == False): + # run_extraction(config, sys_config) + # extracted = True logger.info(f"Starting {strain} suitability ---------------------------------") envSuitPath = workPath + 'post_processing/RIE/'