diff --git a/EnvSuitPipeline.py b/EnvSuitPipeline.py index 90982915652150ff7a507d896a50e2248e0bb148..49d24b2d6800100a37823c7d87c1ea6be6c3165a 100644 --- a/EnvSuitPipeline.py +++ b/EnvSuitPipeline.py @@ -7,8 +7,6 @@ import shutil import pandas as pd from met_processing.runner.common import job_runner -from met_processing.runner.common.generate_all_jobs import generate_all_jobs - MAX_WORKERS: int = 10 @@ -93,7 +91,7 @@ def generate_all(sys_config, run_config): # Run all generate try: - generate_all_jobs(run_config, sys_config, slurm_mode) + job_runner.generate_all_jobs(run_config, sys_config, slurm_mode) except Exception: logger.exception(f"Some failure when running one of the generate job", exc_info=True) raise