diff --git a/Configuration/Applications/python/ConfigBuilder.py b/Configuration/Applications/python/ConfigBuilder.py index 3e3e11fc10da3..7b2a19690e36f 100644 --- a/Configuration/Applications/python/ConfigBuilder.py +++ b/Configuration/Applications/python/ConfigBuilder.py @@ -2268,19 +2268,24 @@ def prepare(self, doChecking = False): self.pythonCfgCode+="from PhysicsTools.PatAlgos.tools.helpers import associatePatAlgosToolsTask\n" self.pythonCfgCode+="associatePatAlgosToolsTask(process)\n" - if self._options.nThreads != "1": + overrideThreads = (self._options.nThreads != "1") + overrideConcurrentLumis = (self._options.nConcurrentLumis != defaultOptions.nConcurrentLumis) + overrideConcurrentIOVs = (self._options.nConcurrentIOVs != defaultOptions.nConcurrentIOVs) + + if overrideThreads or overrideConcurrentLumis or overrideConcurrentIOVs: self.pythonCfgCode +="\n" self.pythonCfgCode +="#Setup FWK for multithreaded\n" - self.pythonCfgCode +="process.options.numberOfThreads = "+self._options.nThreads+"\n" - self.pythonCfgCode +="process.options.numberOfStreams = "+self._options.nStreams+"\n" - self.pythonCfgCode +="process.options.numberOfConcurrentLuminosityBlocks = "+self._options.nConcurrentLumis+"\n" - self.pythonCfgCode +="process.options.eventSetup.numberOfConcurrentIOVs = "+self._options.nConcurrentIOVs+"\n" - if int(self._options.nConcurrentLumis) > 1: - self.pythonCfgCode +="if hasattr(process, 'DQMStore'): process.DQMStore.assertLegacySafe=cms.untracked.bool(False)\n" - self.process.options.numberOfThreads = int(self._options.nThreads) - self.process.options.numberOfStreams = int(self._options.nStreams) - self.process.options.numberOfConcurrentLuminosityBlocks = int(self._options.nConcurrentLumis) - self.process.options.eventSetup.numberOfConcurrentIOVs = int(self._options.nConcurrentIOVs) + if overrideThreads: + self.pythonCfgCode +="process.options.numberOfThreads = "+self._options.nThreads+"\n" + self.pythonCfgCode +="process.options.numberOfStreams = "+self._options.nStreams+"\n" + self.process.options.numberOfThreads = int(self._options.nThreads) + self.process.options.numberOfStreams = int(self._options.nStreams) + if overrideConcurrentLumis: + self.pythonCfgCode +="process.options.numberOfConcurrentLuminosityBlocks = "+self._options.nConcurrentLumis+"\n" + self.process.options.numberOfConcurrentLuminosityBlocks = int(self._options.nConcurrentLumis) + if overrideConcurrentIOVs: + self.pythonCfgCode +="process.options.eventSetup.numberOfConcurrentIOVs = "+self._options.nConcurrentIOVs+"\n" + self.process.options.eventSetup.numberOfConcurrentIOVs = int(self._options.nConcurrentIOVs) if self._options.accelerators is not None: accelerators = self._options.accelerators.split(',')