diff --git a/dartwrf/workflows.py b/dartwrf/workflows.py index 10e7e408fe17ef3682caceca48fcf5e20e24ed7a..9122a18278e6bb0dc79788d35066b0a3b58a497f 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'