more work to unify era5_met_extractor and ews_met_extractor

EnvSuitPipeline.py

@@ -109,9 +109,9 @@ def run_post_processing(run_params: dict, sys_params: dict, processor_name: str)
     logger.info('Data extracted and chunked')
 
 
-def run_merger(run_params: dict, sys_params: dict):
+def run_merger(run_params: dict, sys_params: dict, processor_name: str):
     try:
-        job_runner.run_merge_post_processing(run_params, sys_params)
+        job_runner.run_merge_post_processing(run_params, sys_params, processor_name)
     except Exception:
         logger.exception(f"Some failure when running merge RIE", exc_info=True)
         raise
@@ -218,7 +218,7 @@ def run_pipeline(pipeline_config, region, dateString, extracted = False, prevent
             logger.info(f"Starting {processor_name} post processor ---------------------------------")
             run_post_processing(config, sys_config, processor_name)
 
-            run_merger(config, sys_config)
+            run_merger(config, sys_config, processor_name)
         else:
             strains = getParameter(pipeline_config, 'STRAINS')
 
@@ -251,7 +251,7 @@ def run_pipeline(pipeline_config, region, dateString, extracted = False, prevent
                 envSuitPath = workPath + 'post_processing/RIE/'
                 run_post_processing(config, sys_config, processor_name)
 
-                run_merger(config, sys_config)
+                run_merger(config, sys_config, processor_name)
 
                 resultFile = envSuitPath + 'RIE.csv'
                 strain_outPath = os.path.join(region_outPath,strain)