diff --git a/coordinator/ProcessorAdvisory.py b/coordinator/ProcessorAdvisory.py index c8606a3ff7239fa9f81c682809f5fa38fd3d3625..269087be0d98464edd2deaf44176c7fe2325a381 100644 --- a/coordinator/ProcessorAdvisory.py +++ b/coordinator/ProcessorAdvisory.py @@ -22,6 +22,8 @@ def process_in_job_advisory(jobPath,status,config,component): config_advisory = config[component].copy() + config_advisory['jobPath'] = jobPath + # provide top-level arguments to advisory config for k,v in config.items(): if k not in short_name.keys(): @@ -31,6 +33,8 @@ def process_in_job_advisory(jobPath,status,config,component): layout = 'tight' + logging.info(f"Running for scenario {config_advisory}, {dateString}, {layout}") + report_names = DataGatherer.run_each_subregion(config_advisory, dateString, layout) # pass the report filenames to upload to the remote server