From 26c529cdc27c2f29d86c4af139616b8c443c2c7d Mon Sep 17 00:00:00 2001
From: lb584 <lb584@cam.ac.uk>
Date: Thu, 18 Aug 2022 16:32:01 +0100
Subject: [PATCH] more work to unify era5_met_extractor and ews_met_extractor
---
EnvSuitPipeline.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/EnvSuitPipeline.py b/EnvSuitPipeline.py
index c85d2f7..f503103 100644
--- a/EnvSuitPipeline.py
+++ b/EnvSuitPipeline.py
@@ -103,9 +103,9 @@ def run_extraction(run_params: dict, sys_params: dict):
logger.info('Data extracted and chunked')
-def run_post_processing(run_params: dict, sys_params: dict):
+def run_post_processing(run_params: dict, sys_params: dict, processor_name: str):
logger.info(f"Running post-processing in multi process mode.")
- job_runner.run_post_processing(run_params, sys_params)
+ job_runner.run_post_processing(run_params, sys_params, processor_name)
logger.info('Data extracted and chunked')
@@ -216,7 +216,7 @@ def run_pipeline(pipeline_config, region, dateString, extracted = False, prevent
extracted = True
logger.info(f"Starting {processor_name} post processor ---------------------------------")
- run_post_processing(config, sys_config)
+ run_post_processing(config, sys_config, processor_name)
run_merger(config, sys_config)
else:
@@ -249,7 +249,7 @@ def run_pipeline(pipeline_config, region, dateString, extracted = False, prevent
logger.info(f"Starting {strain} suitability ---------------------------------")
envSuitPath = workPath + 'post_processing/RIE/'
- run_post_processing(config, sys_config)
+ run_post_processing(config, sys_config, processor_name)
run_merger(config, sys_config)
--
GitLab