diff --git a/ews/coordinator/processor_environment.py b/ews/coordinator/processor_environment.py index 57947dc29f1a7a8d99ef7d73a73207d88fa9458f..68005eda5785b8b6fc77ad8e733dffbf97387d7e 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)