diff --git a/MAC/Services/src/PipelineControl.py b/MAC/Services/src/PipelineControl.py index 1a4be9f428304c960c706858a1b7fb40b31cf51e..f41e74a281017bd14ab8bd0af3ca11427c680153 100755 --- a/MAC/Services/src/PipelineControl.py +++ b/MAC/Services/src/PipelineControl.py @@ -123,8 +123,9 @@ class Parset(dict): return self[PARSET_PREFIX + "Observation.Cluster.ProcessingCluster.clusterName"] or "CEP2" def dockerTag(self): - # For now, return OUR tag - return runCommand("docker-template", "${LOFAR_TAG}") + # Return the version set in the parset, and fall back to our own version. + return (self[PARSET_PREFIX + "Observation.ObservationControl.PythonControl.softwareVersion"] or + runCommand("docker-template", "${LOFAR_TAG}")) def slurmJobName(self): return str(self.treeId())