pythonpath

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'