FAQ | This is a LIVE service | Changelog

Skip to content
Snippets Groups Projects
Commit 8f6831f4 authored by L. Bower's avatar L. Bower
Browse files

repackagaing to remove 'common' dirs

parent b6707976
No related branches found
No related tags found
No related merge requests found
...@@ -49,7 +49,7 @@ class ProcessorEnvironment(ProcessorBase): ...@@ -49,7 +49,7 @@ class ProcessorEnvironment(ProcessorBase):
# Processing files available for clearing # Processing files available for clearing
proc_out['clearup'] = [] 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) data_result = get_input_data(jobPath, config, component)
...@@ -59,11 +59,10 @@ class ProcessorEnvironment(ProcessorBase): ...@@ -59,11 +59,10 @@ class ProcessorEnvironment(ProcessorBase):
proc_out['clearup'] += data_result['clearup'] proc_out['clearup'] += data_result['clearup']
region = config['RegionName'] region = config['RegionName']
logger.info(f"Calling environmental suitability 2.0 for {region} so wait for output to appear")
pipeline_config = config["Environment"] pipeline_config = config["Environment"]
try: try:
logger.info(f"Calling environmental suitability 2.0 for {region}")
self.run_pipeline(pipeline_config, region, config["StartString"]) self.run_pipeline(pipeline_config, region, config["StartString"])
except: except:
logger.exception(f"Some failure when running EnvSuitPipeline.py") logger.exception(f"Some failure when running EnvSuitPipeline.py")
...@@ -96,7 +95,7 @@ class ProcessorEnvironment(ProcessorBase): ...@@ -96,7 +95,7 @@ class ProcessorEnvironment(ProcessorBase):
def getParameter(config, parameter): def getParameter(config, parameter):
'''Get a parameter from a config.''' '''Get a parameter from a config.'''
logger.info(f"Getting {parameter} from the config") logger.debug(f"Getting {parameter} from the config")
try: try:
result = config[parameter] result = config[parameter]
...@@ -153,7 +152,7 @@ class ProcessorEnvironment(ProcessorBase): ...@@ -153,7 +152,7 @@ class ProcessorEnvironment(ProcessorBase):
'''Run post processing with the :class:`met_processing.runner.common.job_runner` package.''' '''Run post processing with the :class:`met_processing.runner.common.job_runner` package.'''
logger.info(f"Running post-processing.") 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) job_runner.run_post_processing(run_params, sys_params, processor_name)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment