Skip to content

Commit

Permalink
Merge pull request #35073 from makortel/disableConcurrentLumisAlCa
Browse files Browse the repository at this point in the history
Set numberOfConcurrentLuminosityBlocks to 1 for ALCA sequences that have EDModules that are not planned to support concurrent lumis
  • Loading branch information
cmsbuild authored Aug 31, 2021
2 parents 8318bc2 + ad771a6 commit 59d746b
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 1 deletion.
8 changes: 8 additions & 0 deletions Configuration/AlCa/python/autoAlca.py
Original file line number Diff line number Diff line change
Expand Up @@ -124,3 +124,11 @@ def buildList(pdList, matrix):
'allForPromptCosmics' : buildList(['Cosmics'], AlCaRecoMatrix),
'allForExpressCosmics' : buildList(['ExpressCosmics'], AlCaRecoMatrix) }
autoAlca.update(AlCaRecoMatrix)

# list of AlCa sequences that have modules that do not support concurrent LuminosityBlocks
AlCaNoConcurrentLumis = [
'PromptCalibProd', # AlcaBeamSpotProducer
'PromptCalibProdSiPixelAli', # AlignmentProducerAsAnalyzer, MillePedeFileConverter
'PromptCalibProdBeamSpotHP', # AlcaBeamSpotProducer
'PromptCalibProdBeamSpotHPLowPU', # AlcaBeamSpotProducer
]
6 changes: 5 additions & 1 deletion Configuration/Applications/python/ConfigBuilder.py
Original file line number Diff line number Diff line change
Expand Up @@ -1275,14 +1275,18 @@ def prepare_ALCA(self, sequence = None, workflow = 'full'):
# decide which ALCA paths to use
alcaList = sequence.split("+")
maxLevel=0
from Configuration.AlCa.autoAlca import autoAlca
from Configuration.AlCa.autoAlca import autoAlca, AlCaNoConcurrentLumis
# support @X from autoAlca.py, and recursion support: i.e T0:@Mu+@EG+...
self.expandMapping(alcaList,autoAlca)
self.AlCaPaths=[]
for name in alcaConfig.__dict__:
alcastream = getattr(alcaConfig,name)
shortName = name.replace('ALCARECOStream','')
if shortName in alcaList and isinstance(alcastream,cms.FilteredStream):
if shortName in AlCaNoConcurrentLumis:
print("Setting numberOfConcurrentLuminosityBlocks=1 because of AlCa sequence {}".format(shortName))
self._options.nConcurrentLumis = "1"
self._options.nConcurrentIOVs = "1"
output = self.addExtraStream(name,alcastream, workflow = workflow)
self.executeAndRemember('process.ALCARECOEventContent.outputCommands.extend(process.OutALCARECO'+shortName+'_noDrop.outputCommands)')
self.AlCaPaths.append(shortName)
Expand Down

0 comments on commit 59d746b

Please sign in to comment.