Skip to content
Snippets Groups Projects
Commit d948239e authored by Arne Babenhauserheide's avatar Arne Babenhauserheide
Browse files

tm5: force using only one processor and without mpirun.

parent 4037e6e7
Branches
No related tags found
No related merge requests found
...@@ -515,7 +515,7 @@ class TM5ObservationOperator(ObservationOperator): ...@@ -515,7 +515,7 @@ class TM5ObservationOperator(ObservationOperator):
jobfile = os.path.join(targetdir,'jb.%s.jb'%jobid) jobfile = os.path.join(targetdir,'jb.%s.jb'%jobid)
logfile = jobfile.replace('.jb','.log') logfile = jobfile.replace('.jb','.log')
nprocesses = int(self.DaCycle['da.optimizer.nmembers'])/5 # Note that we assign 5 tracers to each processor, this seems good for TM5 nprocesses = min(1, int(self.DaCycle['da.optimizer.nmembers'])) # )/5 # Note that we assign 5 tracers to each processor, this seems good for TM5
jobparams = {'jobname':'tm5', jobparams = {'jobname':'tm5',
'jobnodes':'ncomp %d'%int(nprocesses), 'jobnodes':'ncomp %d'%int(nprocesses),
'jobtime':'00:30:00', 'jobtime':'00:30:00',
...@@ -524,7 +524,11 @@ class TM5ObservationOperator(ObservationOperator): ...@@ -524,7 +524,11 @@ class TM5ObservationOperator(ObservationOperator):
template = DaPlatForm.GetJobTemplate(jobparams,block=True) template = DaPlatForm.GetJobTemplate(jobparams,block=True)
template += 'cd %s\n'%targetdir template += 'cd %s\n'%targetdir
template += '%s -np %d %s tm5.rc\n'%(self.tm_settings['mpirun.command'],int(nprocesses),self.Tm5Executable,) # avoid mpi if we only use one process
if nprocesses > 1:
template += '%s -np %d %s tm5.rc\n'%(self.tm_settings['mpirun.command'],int(nprocesses),self.Tm5Executable,)
else:
template += '%s tm5.rc\n'%(self.Tm5Executable,)
dummy = DaPlatForm.WriteJob(jobfile,template,jobid) dummy = DaPlatForm.WriteJob(jobfile,template,jobid)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment