From 045534f5f8d144d7fb4739c839015653b1bc8f7b Mon Sep 17 00:00:00 2001
From: lb584 <lb584@cam.ac.uk>
Date: Mon, 6 Nov 2023 15:35:59 +0000
Subject: [PATCH] removing redundant calls to Extract (will delete this code in
due course)
---
coordinator/EnvSuitPipeline.py | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
diff --git a/coordinator/EnvSuitPipeline.py b/coordinator/EnvSuitPipeline.py
index f790a10..daf5e3a 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/'
--
GitLab