Inheritance diagram for Impl.AlCaNano.AlCaNano:

Public Member Functions
def	__init__ (self)

def	alcaHarvesting (self, globalTag, datasetName, args)

def	alcaSkim (self, skims, args)

def	dqmHarvesting (self, datasetName, runNumber, globalTag, args)

def	expressProcessing (self, globalTag, args)

def	promptReco (self, globalTag, args)

def	skimsIfNotGiven (self, args, sl)

Public Attributes
	promptCustoms

	promptModifiers

	recoSeq

Detailed Description

Definition at line 17 of file AlCaNano.py.

Constructor & Destructor Documentation

◆ init()

def Impl.AlCaNano.AlCaNano.__init__ ( self )

Definition at line 18 of file AlCaNano.py.

     def __init__(self):
         Scenario.__init__(self)
         self.recoSeq=''
         self.promptCustoms= [ 'Configuration/DataProcessing/RecoTLR.customisePrompt' ]
         self.promptModifiers = cms.ModifierChain()
 

Member Function Documentation

◆ alcaHarvesting()

def Impl.AlCaNano.AlCaNano.alcaHarvesting	(	self,
		globalTag,
		datasetName,
		args
	)

_alcaHarvesting_
Proton collisions data taking AlCa Harvesting

Definition at line 134 of file AlCaNano.py.

     def alcaHarvesting(self, globalTag, datasetName, **args):
         """
         _alcaHarvesting_
         Proton collisions data taking AlCa Harvesting
         """
         skims = []
         if 'skims' in args:
             skims = args['skims']
 
 
         if 'alcapromptdataset' in args:
             skims.append('@'+args['alcapromptdataset'])
 
         if len(skims) == 0: return None
         options = defaultOptions
         options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
         options.step = "ALCAHARVEST:"+('+'.join(skims))
         options.name = "ALCAHARVEST"
         options.conditions = gtNameAndConnect(globalTag, args)
 
         process = cms.Process("ALCAHARVEST", self.eras)
         process.source = cms.Source("PoolSource")
 
         if 'customs' in args:
             options.customisation_file=args['customs']
 
         configBuilder = ConfigBuilder(options, process = process)
         configBuilder.prepare()
 
         process.source.processingMode = cms.untracked.string('RunsAndLumis')
         process.source.fileNames = cms.untracked(cms.vstring())
         process.maxEvents.input = -1
         process.dqmSaver.workflow = datasetName
 
         return process
 

◆ alcaSkim()

def Impl.AlCaNano.AlCaNano.alcaSkim	(	self,
		skims,
		args
	)

_alcaSkim_
AlcaReco processing & skims for proton collisions

Definition at line 69 of file AlCaNano.py.

     def alcaSkim(self, skims, **args):
         """
         _alcaSkim_
         AlcaReco processing & skims for proton collisions
         """
         step = ""
         pclWflws = [x for x in skims if "PromptCalibProd" in x]
         skims = [x for x in skims if x not in pclWflws]
 
         if len(pclWflws):
             step += 'ALCA:'+('+'.join(pclWflws))
 
         if len(skims) > 0:
             if step != "":
                 step += ","
             step += "ALCAOUTPUT:"+('+'.join(skims))
 
         options = Options()
         options.__dict__.update(defaultOptions.__dict__)
         options.scenario = "pp"
         options.step = step
         options.conditions = args['globaltag'] if 'globaltag' in args else 'None'
         if 'globalTagConnect' in args and args['globalTagConnect'] != '':
             options.conditions += ','+args['globalTagConnect']
 
         options.triggerResultsProcess = 'RECO'
 
         process = cms.Process('ALCA', self.eras)
         cb = ConfigBuilder(options, process=process)
 
         # Input source
         process.source = cms.Source(
            "PoolSource",
            fileNames=cms.untracked.vstring()
         )
 
         cb.prepare()
 
         for wfl in pclWflws:
             methodToCall = getattr(process, 'ALCARECOStream'+wfl)
             methodToCall.dataset.dataTier = cms.untracked.string('ALCAPROMPT')
 
         return process
 
 

◆ dqmHarvesting()

def Impl.AlCaNano.AlCaNano.dqmHarvesting	(	self,
		datasetName,
		runNumber,
		globalTag,
		args
	)

_dqmHarvesting_
Proton collisions data taking DQM Harvesting

Definition at line 114 of file AlCaNano.py.

     def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
         """
         _dqmHarvesting_
         Proton collisions data taking DQM Harvesting
         """
         options = defaultOptions
         options.scenario = "pp"
         options.step = "HARVESTING:alcaHarvesting"
         options.name = "EDMtoMEConvert"
         options.conditions = gtNameAndConnect(globalTag, args)
 
         process = cms.Process("HARVESTING", self.eras)
         process.source = dqmIOSource(args)
         configBuilder = ConfigBuilder(options, process = process)
         configBuilder.prepare()
 
         harvestingMode(process,datasetName,args)
 
         return process
 

◆ expressProcessing()

def Impl.AlCaNano.AlCaNano.expressProcessing	(	self,
		globalTag,
		args
	)

_expressProcessing_
Proton collision data taking express processing

Definition at line 170 of file AlCaNano.py.

References Utils.addMonitoring(), Impl.AlCaLumiPixels_Run3.AlCaLumiPixels_Run3.eras, Impl.AlCaLumiPixels.AlCaLumiPixels.eras, Impl.AlCaPhiSymEcal_Nano.AlCaPhiSymEcal_Nano.eras, Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_2017.cosmicsEra_Run2_2017.eras, Impl.cosmicsEra_Run2_2018.cosmicsEra_Run2_2018.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run3.cosmicsEra_Run3.eras, Impl.cosmicsHybridEra_Run2_2018.cosmicsHybridEra_Run2_2018.eras, Impl.hcalnzsEra_Run2_2018_pp_on_AA.hcalnzsEra_Run2_2018_pp_on_AA.eras, Impl.hcalnzsEra_Run3_pp_on_PbPb.hcalnzsEra_Run3_pp_on_PbPb.eras, Impl.hcalnzsEra_Run2_2017.hcalnzsEra_Run2_2017.eras, Impl.hcalnzsEra_Run2_2018.hcalnzsEra_Run2_2018.eras, Impl.hcalnzsEra_Run2_2018_highBetaStar.hcalnzsEra_Run2_2018_highBetaStar.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run3.hcalnzsEra_Run3.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.HeavyIonsEra_Run2_2018.HeavyIonsEra_Run2_2018.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.AlCaPPS_Run3.AlCaPPS_Run3.eras, Impl.ppEra_Run2_2018.ppEra_Run2_2018.eras, Impl.ppEra_Run2_2017_trackingLowPU.ppEra_Run2_2017_trackingLowPU.eras, Impl.ppEra_Run2_2018_highBetaStar.ppEra_Run2_2018_highBetaStar.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run3_2023.ppEra_Run3_2023.eras, Impl.ppEra_Run3.ppEra_Run3.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.ppEra_Run2_2017.ppEra_Run2_2017.eras, Impl.ppEra_Run2_2017_ppRef.ppEra_Run2_2017_ppRef.eras, Impl.ppEra_Run3_pp_on_PbPb_2023.ppEra_Run3_pp_on_PbPb_2023.eras, Impl.ppEra_Run2_2018_pp_on_AA.ppEra_Run2_2018_pp_on_AA.eras, Impl.ppEra_Run3_pp_on_PbPb.ppEra_Run3_pp_on_PbPb.eras, Impl.ppEra_Run3_2023_repacked.ppEra_Run3_2023_repacked.eras, Impl.ppEra_Run3_pp_on_PbPb_approxSiStripClusters_2023.ppEra_Run3_pp_on_PbPb_approxSiStripClusters_2023.eras, Impl.ppEra_Run3_pp_on_PbPb_approxSiStripClusters.ppEra_Run3_pp_on_PbPb_approxSiStripClusters.eras, Impl.trackingOnlyEra_Run2_2018_pp_on_AA.trackingOnlyEra_Run2_2018_pp_on_AA.eras, Impl.trackingOnlyEra_Run3_pp_on_PbPb.trackingOnlyEra_Run3_pp_on_PbPb.eras, Impl.ppEra_Run2_2017_pp_on_XeXe.ppEra_Run2_2017_pp_on_XeXe.eras, Impl.ppEra_Run2_2017_trackingOnly.ppEra_Run2_2017_trackingOnly.eras, Impl.trackingOnlyEra_Run3.trackingOnlyEra_Run3.eras, Impl.trackingOnlyEra_Run2_2018_highBetaStar.trackingOnlyEra_Run2_2018_highBetaStar.eras, Impl.trackingOnlyEra_Run2_2017.trackingOnlyEra_Run2_2017.eras, Impl.trackingOnlyEra_Run2_2018.trackingOnlyEra_Run2_2018.eras, Scenario.Scenario.eras, options.HLTProcessOptions.eras, Utils.gtNameAndConnect(), print(), and Utils.stepALCAPRODUCER().

     def expressProcessing(self, globalTag, **args):
         """
         _expressProcessing_
         Proton collision data taking express processing
         """
         skims = []
         if 'skims' in args:
             skims = args['skims']
             pclWkflws = [x for x in skims if "PromptCalibProd" in x]
             for wfl in pclWkflws:
                 skims.remove(wfl)
 
         options = Options()
         options.__dict__.update(defaultOptions.__dict__)
         options.scenario = "pp"
         options.step = stepALCAPRODUCER(skims)
 
         if 'outputs' in args:
             # the RAW data-tier needs a special treatment since the event-content as defined in release is not good enough
             outputs_Raw = [x for x in args['outputs'] if x['dataTier'] == 'RAW']
             outputs_noRaw = [x for x in args['outputs'] if x['dataTier'] != 'RAW']
             if len(outputs_Raw) == 1:
                 print('RAW data-tier requested')
             options.outputDefinition = outputs_noRaw.__str__()
 
         options.conditions = gtNameAndConnect(globalTag, args)
 
         options.filein = 'tobeoverwritten.xyz'
         if 'inputSource' in args:
             options.filetype = args['inputSource']
         process = cms.Process('RECO', self.eras)
 
         if 'customs' in args:
             options.customisation_file=args['customs']
 
         cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
 
         cb.prepare()
 
         addMonitoring(process)
 
         for output in outputs_Raw:
             print(output)
             moduleLabel = output['moduleLabel']
             selectEvents = output.get('selectEvents', None)
             maxSize = output.get('maxSize', None)
 
             outputModule = cms.OutputModule(
                 "PoolOutputModule",
                 fileName = cms.untracked.string("%s.root" % moduleLabel)
                 )
 
             outputModule.dataset = cms.untracked.PSet(dataTier = cms.untracked.string("RAW"))
 
             if maxSize != None:
                 outputModule.maxSize = cms.untracked.int32(maxSize)
 
             if selectEvents != None:
                 outputModule.SelectEvents = cms.untracked.PSet(
                     SelectEvents = cms.vstring(selectEvents)
                     )
             outputModule.outputCommands = cms.untracked.vstring('drop *',
                                                                 'keep  *_*_*_HLT')
 
             setattr(process, moduleLabel, outputModule)
             # outputModule=getattr(self.process,theModuleLabel)
             setattr(process, moduleLabel+'_step', cms.EndPath(outputModule))
             path = getattr(process, moduleLabel+'_step')
             process.schedule.append(path)
 
         return process
 

◆ promptReco()

def Impl.AlCaNano.AlCaNano.promptReco	(	self,
		globalTag,
		args
	)

Definition at line 36 of file AlCaNano.py.

     def promptReco(self, globalTag, **args):
         if not 'skims' in args:
             args['skims']=self.skims
         if not 'customs' in args:
             args['customs']= [ ]
         for c in self.promptCustoms:
             args['customs'].append(c)
 
         options = Options()
         options.__dict__.update(defaultOptions.__dict__)
         options.scenario = "pp"
         dictIO(options,args)
         options.conditions = gtNameAndConnect(globalTag, args)
 
         if 'customs' in args:
             print(args['customs'])
             options.customisation_file=args['customs']
 
         options.step = 'RECO'
         options.step += self.recoSeq
         options.step += stepALCAPRODUCER(args['skims'])
 
         process = cms.Process('RECO', cms.ModifierChain(self.eras, self.promptModifiers) )
         cb = ConfigBuilder(options, process = process, with_output = True)
 
         # Input source
         process.source = cms.Source("PoolSource",
             fileNames = cms.untracked.vstring()
         )
         cb.prepare()
 
         return process
 

◆ skimsIfNotGiven()

def Impl.AlCaNano.AlCaNano.skimsIfNotGiven	(	self,
		args,
		sl
	)

Definition at line 32 of file AlCaNano.py.

     def skimsIfNotGiven(self,args,sl):
         if not 'skims' in args:
             args['skims']=sl
 

Member Data Documentation

◆ promptCustoms

Impl.AlCaNano.AlCaNano.promptCustoms

Definition at line 21 of file AlCaNano.py.

Referenced by Impl.AlCaNano.AlCaNano.promptReco(), Impl.pp.pp.promptReco(), and Impl.HeavyIons.HeavyIons.promptReco().

◆ promptModifiers

Impl.AlCaNano.AlCaNano.promptModifiers

Definition at line 22 of file AlCaNano.py.

Referenced by Impl.AlCaNano.AlCaNano.promptReco(), and Reco.Reco.promptReco().

◆ recoSeq

Impl.AlCaNano.AlCaNano.recoSeq

Definition at line 20 of file AlCaNano.py.

Referenced by Reco.Reco.expressProcessing(), Impl.AlCaNano.AlCaNano.promptReco(), and Reco.Reco.promptReco().

Public Member Functions

Public Attributes