Inheritance diagram for Impl.AlCa.AlCa:

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)

Detailed Description

Definition at line 17 of file AlCa.py.

Constructor & Destructor Documentation

◆ init()

def Impl.AlCa.AlCa.__init__ ( self )

Definition at line 18 of file AlCa.py.

     def __init__(self):
         Scenario.__init__(self)
 

Member Function Documentation

◆ alcaHarvesting()

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

_alcaHarvesting_

Proton collisions data taking AlCa Harvesting

Definition at line 134 of file AlCa.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()
 
         #
         # customise process for particular job
         #
         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.AlCa.AlCa.alcaSkim	(	self,
		skims,
		args
	)

_alcaSkim_

AlcaReco processing & skims for proton collisions

Definition at line 55 of file AlCa.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()
 
         # FIXME: dirty hack..any way around this?
         # Tier0 needs the dataset used for ALCAHARVEST step to be a different data-tier
         for wfl in pclWflws:
             methodToCall = getattr(process, 'ALCARECOStream'+wfl)
             methodToCall.dataset.dataTier = cms.untracked.string('ALCAPROMPT')
 
         return process
 
 

◆ dqmHarvesting()

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

_dqmHarvesting_

Proton collisions data taking DQM Harvesting

Definition at line 104 of file AlCa.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()
 
         #
         # customise process for particular job
         #
         #process.source.processingMode = cms.untracked.string('RunsAndLumis')
         #process.source.fileNames = cms.untracked(cms.vstring())
         #process.maxEvents.input = -1
         #process.dqmSaver.workflow = datasetName
         #process.dqmSaver.saveByLumiSection = 1
         harvestingMode(process,datasetName,args)
 
         return process
 

◆ expressProcessing()

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

_expressProcessing_

Proton collision data taking express processing

Definition at line 175 of file AlCa.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__()
 
         # dictIO(options,args)
         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.AlCa.AlCa.promptReco	(	self,
		globalTag,
		args
	)

Definition at line 33 of file AlCa.py.

     def promptReco(self, globalTag, **args):
         if not 'skims' in args:
             args['skims']=self.skims
         step = stepALCAPRODUCER(args['skims'])
         options = Options()
         options.__dict__.update(defaultOptions.__dict__)
         options.scenario = "pp"
         options.step = step
         dictIO(options,args)
         options.conditions = gtNameAndConnect(globalTag, args)
 
         process = cms.Process('RECO', self.eras)
         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.AlCa.AlCa.skimsIfNotGiven	(	self,
		args,
		sl
	)

Definition at line 29 of file AlCa.py.

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

Public Member Functions