diff --git a/MAC/Services/src/PipelineControl.py b/MAC/Services/src/PipelineControl.py index a92d80022ed3fe61f717807e35e278b447266efe..19edb2ca30d6eb249446850825f7bc211e2e222d 100755 --- a/MAC/Services/src/PipelineControl.py +++ b/MAC/Services/src/PipelineControl.py @@ -203,9 +203,6 @@ class Slurm(object): def __init__(self, headnode="head01.cep4.control.lofar"): self.headnode = headnode - # TODO: Derive SLURM partition name - self.partition = "cpu" - def _runCommand(self, cmdline, input=None): cmdline = "ssh %s %s" % (self.headnode, cmdline) return runCommand(cmdline, input) @@ -218,7 +215,7 @@ class Slurm(object): {cmdline} """.format(cmdline = cmdline) - stdout = self._runCommand("sbatch --partition=%s --job-name=%s %s" % (self.partition, jobName, " ".join(sbatch_params)), script) + stdout = self._runCommand("sbatch --job-name=%s %s" % (jobName, " ".join(sbatch_params)), script) # Returns "Submitted batch job 3" -- extract ID match = re.search("Submitted batch job (\d+)", stdout)