diff --git a/MAC/Services/src/PipelineControl.py b/MAC/Services/src/PipelineControl.py index 74d5d04f40b90becd3d4ddd101d829da535276ab..95e265bd310d46f53fec58fc3400a0dd43f0a3c7 100755 --- a/MAC/Services/src/PipelineControl.py +++ b/MAC/Services/src/PipelineControl.py @@ -437,6 +437,9 @@ class PipelineControl(OTDBBusListener): status_bus = self.otdb_service_busname, )) + logger.info("Handing over pipeline %s to SLURM, setting status to QUEUED", otdbId) + self._setStatus(otdbId, "queued") + # Schedule runPipeline.sh logger.info("Scheduling SLURM job for runPipeline.sh") slurm_job_id = self.slurm.submit(self._jobName(otdbId), @@ -558,9 +561,6 @@ wget -O - -q "http://ganglia.control.lofar/ganglia/api/events.php?action=add&sta ) logger.info("Scheduled SLURM job %s", slurm_cancel_job_id) - logger.info("Setting status to QUEUED") - self._setStatus(otdbId, "queued") - def _stopPipeline(self, otdbId): # Cancel corresponding SLURM job, but first the abort-trigger # to avoid setting ABORTED as a side effect.