From 4379f6651a2ddc85551a7b20904deea2846a6ac3 Mon Sep 17 00:00:00 2001 From: Cristian Lalescu <Cristian.Lalescu@ds.mpg.de> Date: Mon, 24 Sep 2018 12:54:43 +0200 Subject: [PATCH] fix sge script generation --- bfps/_code.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/bfps/_code.py b/bfps/_code.py index 143ef29a..c29dda63 100644 --- a/bfps/_code.py +++ b/bfps/_code.py @@ -281,11 +281,12 @@ class _code(_base): nb_threads_per_process = nb_threads_per_process) os.chdir(self.work_dir) qsub_atoms = ['qsub'] - if len(job_name_list) >= 1: - qsub_atoms += ['-hold_jid', job_name_list[-1]] - subprocess.check_call(qsub_atoms + [qsub_script_name]) - os.chdir(current_dir) - job_name_list.append(suffix) + if not no_submit: + if len(job_name_list) >= 1: + qsub_atoms += ['-hold_jid', job_name_list[-1]] + subprocess.check_call(qsub_atoms + [qsub_script_name]) + os.chdir(current_dir) + job_name_list.append(suffix) if self.host_info['type'] == 'SLURM': job_id_list = [] for j in range(njobs): @@ -584,7 +585,7 @@ class _code(_base): if not type(out_file) == type(None): script_file.write('#$ -o ' + out_file + '\n') if not type(self.host_info['environment']) == type(None): - envprocs = self.host_info['deltanprocs'] * int(math.ceil((nprocesses *1.0/ self.host_info['deltanprocs']))) + envprocs = nb_threads_per_process * nprocesses script_file.write('#$ -pe {0} {1}\n'.format( self.host_info['environment'], envprocs)) -- GitLab