Inheritance diagram for Impl.AlCa.AlCa:

Public Member Functions
def	__init__ (self)

def	alcaSkim (self, skims, args)

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

def	promptReco (self, globalTag, args)

def	skimsIfNotGiven (self, args, sl)

Detailed Description

Definition at line 16 of file AlCa.py.

Constructor & Destructor Documentation

def Impl.AlCa.AlCa.__init__ ( self )

Definition at line 17 of file AlCa.py.

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

Member Function Documentation

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

_alcaSkim_

AlcaReco processing & skims for proton collisions

Definition at line 54 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 = filter(lambda x: x not in pclWflws, skims)
 
         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
 
 

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

_dqmHarvesting_

Proton collisions data taking DQM Harvesting

Definition at line 103 of file AlCa.py.

References Utils.dqmIOSource(), Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_2017.cosmicsEra_Run2_2017.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_2017.hcalnzsEra_Run2_2017.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.ppEra_Run2_2017.ppEra_Run2_2017.eras, Impl.ppEra_Run2_2017_trackingLowPU.ppEra_Run2_2017_trackingLowPU.eras, Impl.ppEra_Run2_2017_trackingOnly.ppEra_Run2_2017_trackingOnly.eras, Scenario.Scenario.eras, options.HLTProcessOptions.eras, Utils.gtNameAndConnect(), and Utils.harvestingMode().

     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
         #if args.has_key('referenceFile') and args.get('referenceFile', ''):
         #    process.DQMStore.referenceFileName = \
         #                        cms.untracked.string(args['referenceFile'])
         harvestingMode(process,datasetName,args)
 
         return process

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

Definition at line 32 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
 

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

Definition at line 28 of file AlCa.py.

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

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation