From 23c8433bef3896fe0dd8d560f95d0f4f3d77f01c Mon Sep 17 00:00:00 2001 From: lkugler <lukas.kugler@gmail.com> Date: Wed, 31 May 2023 11:56:01 +0200 Subject: [PATCH] pythonpath --- dartwrf/workflows.py | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/dartwrf/workflows.py b/dartwrf/workflows.py index 10e7e40..9122a18 100644 --- a/dartwrf/workflows.py +++ b/dartwrf/workflows.py @@ -117,7 +117,8 @@ class WorkFlows(object): _copy_dartwrf_to_archive() # includes config files # we set the path from where python should import dartwrf modules - self.cluster.python = 'export PYTHONPATH='+self.cluster.scripts_rundir+'; '+self.cluster.python + # pythonpath is the folder above the dartwrf folder + self.cluster.python = 'export PYTHONPATH='+self.cluster.scripts_rundir+'/../; '+self.cluster.python # Set paths and backup scripts self.cluster.log_dir = self.cluster.archivedir+'/logs/' @@ -333,6 +334,15 @@ class WorkFlows(object): depends_on=[depends_on]) return id + def evaluate_plus0(self, list_assim_times, depends_on=None): + list_of_tuples = [(init, init) for init in list_assim_times] + arg = ' '.join([ttuple[0].strftime('%Y-%m-%d_%H:%M,')+ttuple[1].strftime('%Y-%m-%d_%H:%M') for ttuple in list_of_tuples]) + + cmd = self.cluster.python+' '+self.cluster.scripts_rundir+'/evaluate_obs_space.py '+arg + id = self.cluster.run_job(cmd, 'eval+0'+self.exp.expname, cfg_update={"ntasks": "12", "mem": "50G", "ntasks-per-node": "12", "ntasks-per-core": "2", + "time": "15", "mail-type": "FAIL"}, + depends_on=[depends_on]) + return id def verify_sat(self, depends_on=None): cmd = self.cluster.python_verif+' /jetfs/home/lkugler/osse_analysis/plot_from_raw/analyze_fc.py '+self.exp.expname+' has_node sat verif1d FSS BS' -- GitLab