From 2cc847c5e95da8313504254689bcec6464d3041f Mon Sep 17 00:00:00 2001
From: Lukas Kugler <lukas.kugler@univie.ac.at>
Date: Fri, 14 Feb 2025 11:31:19 +0100
Subject: [PATCH] cfg needs deep copy
---
dartwrf/workflows.py | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
diff --git a/dartwrf/workflows.py b/dartwrf/workflows.py
index 10b6be6..029233a 100644
--- a/dartwrf/workflows.py
+++ b/dartwrf/workflows.py
@@ -95,7 +95,7 @@ class WorkFlows(object):
jobname = path_to_script.split('/')[-1]+'-'+cfg.f_cfg_current.split('/')[-1].replace('.py','')
print('> SLURM job:', jobname)
- slurm_kwargs = cfg.slurm_kwargs
+ slurm_kwargs = cfg.slurm_kwargs.copy()
for key, value in kwargs.items():
slurm_kwargs[key] = value
@@ -180,7 +180,7 @@ class WorkFlows(object):
).replace('<wrf_rundir_base>', cfg.dir_wrf_run
).replace('<wrf_modules>', cfg.wrf_modules,
)
- id = self.run_job(cmd, cfg, depends_on=[depends_on])
+ id = self.run_job(cmd, cfg, depends_on=[depends_on], time="30")
return id
def run_WRF(self, cfg, depends_on=None):
@@ -235,7 +235,7 @@ class WorkFlows(object):
)
return id
- def prepare_IC_from_prior(self, cfg, depends_on=None):
+ def prepare_IC_from_prior(self, cfg: Config, depends_on=None):
"""Create initial conditions from prior wrfrst files
Args:
@@ -252,8 +252,7 @@ class WorkFlows(object):
"""
path_to_script = self.dir_dartwrf_run + '/prep_IC_prior.py'
cmd = ' '.join([self.python, path_to_script, cfg.f_cfg_current])
-
- id = self.run_job(cmd, cfg, depends_on=[depends_on])
+ id = self.run_job(cmd, cfg, depends_on=[depends_on], time="10")
return id
def update_IC_from_DA(self, cfg, depends_on=None):
@@ -269,7 +268,7 @@ class WorkFlows(object):
path_to_script = self.dir_dartwrf_run + '/update_IC.py'
cmd = ' '.join([self.python, path_to_script, cfg.f_cfg_current])
- id = self.run_job(cmd, cfg, depends_on=[depends_on])
+ id = self.run_job(cmd, cfg, depends_on=[depends_on], time="10")
return id
def create_satimages(self, cfg, depends_on=None):
--
GitLab