From 8f6831f4511d59f12effac1cf69962dcaf3a7ac5 Mon Sep 17 00:00:00 2001
From: lb584 <lb584@cam.ac.uk>
Date: Wed, 22 May 2024 14:43:20 +0100
Subject: [PATCH] repackagaing to remove 'common' dirs
---
ews/coordinator/processor_environment.py | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
diff --git a/ews/coordinator/processor_environment.py b/ews/coordinator/processor_environment.py
index 57947dc..68005ed 100644
--- a/ews/coordinator/processor_environment.py
+++ b/ews/coordinator/processor_environment.py
@@ -49,7 +49,7 @@ class ProcessorEnvironment(ProcessorBase):
# Processing files available for clearing
proc_out['clearup'] = []
- logger.info('Copying file from remote server to job directory')
+ logger.debug('Copying file from remote server to job directory')
data_result = get_input_data(jobPath, config, component)
@@ -59,11 +59,10 @@ class ProcessorEnvironment(ProcessorBase):
proc_out['clearup'] += data_result['clearup']
region = config['RegionName']
-
- logger.info(f"Calling environmental suitability 2.0 for {region} so wait for output to appear")
-
+
pipeline_config = config["Environment"]
try:
+ logger.info(f"Calling environmental suitability 2.0 for {region}")
self.run_pipeline(pipeline_config, region, config["StartString"])
except:
logger.exception(f"Some failure when running EnvSuitPipeline.py")
@@ -96,7 +95,7 @@ class ProcessorEnvironment(ProcessorBase):
def getParameter(config, parameter):
'''Get a parameter from a config.'''
- logger.info(f"Getting {parameter} from the config")
+ logger.debug(f"Getting {parameter} from the config")
try:
result = config[parameter]
@@ -153,7 +152,7 @@ class ProcessorEnvironment(ProcessorBase):
'''Run post processing with the :class:`met_processing.runner.common.job_runner` package.'''
logger.info(f"Running post-processing.")
- from ews.met_processing.runner.common import job_runner
+ from ews.met_processing.runner import job_runner
job_runner.run_post_processing(run_params, sys_params, processor_name)
--
GitLab