Inheritance diagram for Reco.Reco:

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	skimming (self, skims, globalTag, options)

def	visualizationProcessing (self, globalTag, args)

Public Attributes
	cbSc

	expressModifiers

	promptModifiers

	recoSeq

	visModifiers

Private Member Functions
def	_checkRepackedFlag (self, options, args)

Detailed Description

Definition at line 17 of file Reco.py.

Constructor & Destructor Documentation

def Reco.Reco.__init__ ( self )

Definition at line 18 of file Reco.py.

     def __init__(self):
         Scenario.__init__(self)
         self.recoSeq=''
         self.cbSc=self.__class__.__name__
         self.promptModifiers = cms.ModifierChain()
         self.expressModifiers = cms.ModifierChain()
         self.visModifiers = cms.ModifierChain()

Member Function Documentation

def Reco.Reco._checkRepackedFlag	(	self,
		options,
		args
	)

private

Definition at line 34 of file Reco.py.

Referenced by Reco.Reco.expressProcessing(), Reco.Reco.promptReco(), and Reco.Reco.visualizationProcessing().

     def _checkRepackedFlag(self, options, **args):
         if 'repacked' in args:
             if args['repacked'] == True:
                 options.isRepacked = True
             else:
                 options.isRepacked = False
                 
 
 

def Reco.Reco.alcaHarvesting	(	self,
		globalTag,
		datasetName,
		args
	)

_alcaHarvesting_

Proton collisions data taking AlCa Harvesting

Definition at line 284 of file Reco.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
 

def Reco.Reco.alcaSkim	(	self,
		skims,
		args
	)

_alcaSkim_

AlcaReco processing & skims for proton collisions

Definition at line 205 of file Reco.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 = self.cbSc
         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'
 
         if 'customs' in args:
             options.customisation_file=args['customs']
         
         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 Reco.Reco.dqmHarvesting	(	self,
		datasetName,
		runNumber,
		globalTag,
		args
	)

_dqmHarvesting_

Proton collisions data taking DQM Harvesting

Definition at line 258 of file Reco.py.

References Impl.cosmics.cosmics.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsEra_Run2_2017.hcalnzsEra_Run2_2017.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.pp.pp.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_2017.ppEra_Run2_2017.cbSc, Impl.ppEra_Run2_2017_trackingLowPU.ppEra_Run2_2017_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Utils.dqmIOSource(), Utils.dqmSeq(), Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_2017.cosmicsEra_Run2_2017.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_2017.hcalnzsEra_Run2_2017.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2017.ppEra_Run2_2017.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_trackingLowPU.ppEra_Run2_2017_trackingLowPU.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.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 = self.cbSc
         options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
         options.name = "EDMtoMEConvert"
         options.conditions = gtNameAndConnect(globalTag, args)
  
         process = cms.Process("HARVESTING", self.eras)
         process.source = dqmIOSource(args)
 
         if 'customs' in args:
             options.customisation_file=args['customs']
 
         configBuilder = ConfigBuilder(options, process = process)
         configBuilder.prepare()
 
         harvestingMode(process,datasetName,args,rANDl=False)
         return process
 
 

def Reco.Reco.expressProcessing	(	self,
		globalTag,
		args
	)

_expressProcessing_

Proton collision data taking express processing

Definition at line 101 of file Reco.py.

References Reco.Reco._checkRepackedFlag(), Utils.addMonitoring(), Impl.cosmics.cosmics.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.hcalnzsEra_Run2_2017.hcalnzsEra_Run2_2017.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.pp.pp.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_2017.ppEra_Run2_2017.cbSc, Impl.ppEra_Run2_2017_trackingLowPU.ppEra_Run2_2017_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Utils.dictIO(), Utils.dqmSeq(), Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_2017.cosmicsEra_Run2_2017.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_2017.hcalnzsEra_Run2_2017.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2017_trackingLowPU.ppEra_Run2_2017_trackingLowPU.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_2017.ppEra_Run2_2017.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Scenario.Scenario.eras, options.HLTProcessOptions.eras, Impl.HeavyIons.HeavyIons.expressModifiers, Reco.Reco.expressModifiers, Impl.pp.pp.expressModifiers, Utils.gtNameAndConnect(), and Utils.stepALCAPRODUCER().

     def expressProcessing(self, globalTag, **args):
         """
         _expressProcessing_
 
         Proton collision data taking express processing
 
         """
         skims = args['skims']
         # the AlCaReco skims for PCL should only run during AlCaSkimming step which uses the same configuration on the Tier0 side, for this reason we drop them here
         pclWkflws = [x for x in skims if "PromptCalibProd" in x]
         for wfl in pclWkflws:
             skims.remove(wfl)
         
         step = stepALCAPRODUCER(skims)
         dqmStep= dqmSeq(args,'')
         options = Options()
         options.__dict__.update(defaultOptions.__dict__)
         options.scenario = self.cbSc
 
         eiStep=''
         if self.cbSc == 'pp':
             eiStep=',EI'
 
         options.step = 'RAW2DIGI,L1Reco,RECO'+eiStep+step+',DQM'+dqmStep+',ENDJOB'
         dictIO(options,args)
         options.conditions = gtNameAndConnect(globalTag, args)
 
         
         options.filein = 'tobeoverwritten.xyz'
         if 'inputSource' in args:
             options.filetype = args['inputSource']
         process = cms.Process('RECO', cms.ModifierChain(self.eras, self.expressModifiers) )
 
         if 'customs' in args:
             options.customisation_file=args['customs']
 
         self._checkRepackedFlag(options,**args)
 
         cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
 
         cb.prepare()
 
         addMonitoring(process)
                 
         return process
 
 

def Reco.Reco.promptReco	(	self,
		globalTag,
		args
	)

_promptReco_

Proton collision data taking prompt reco

Definition at line 43 of file Reco.py.

     def promptReco(self, globalTag, **args):
         """
         _promptReco_
 
         Proton collision data taking prompt reco
 
         """
         step = stepALCAPRODUCER(args['skims'])
         PhysicsSkimStep = ''
         if ("PhysicsSkims" in args) :
             PhysicsSkimStep = stepSKIMPRODUCER(args['PhysicsSkims'])
         dqmStep= dqmSeq(args,'')
         options = Options()
         options.__dict__.update(defaultOptions.__dict__)
         options.scenario = self.cbSc
 
         miniAODStep=''
 
 # if miniAOD is asked for - then retrieve the miniaod config 
         if 'outputs' in args:
             for a in args['outputs']:
                 if a['dataTier'] == 'MINIAOD':
                     miniAODStep=',PAT' 
 
         """
         Unscheduled for all
         """
         options.runUnscheduled=True
                     
         self._checkRepackedFlag(options, **args)
 
         if 'customs' in args:
             options.customisation_file=args['customs']
 
         eiStep=''
         if self.cbSc == 'pp':
             eiStep=',EI'
 
         options.step = 'RAW2DIGI,L1Reco,RECO'+self.recoSeq+eiStep+step+PhysicsSkimStep+miniAODStep+',DQM'+dqmStep+',ENDJOB'
 
 
         dictIO(options,args)
         options.conditions = gtNameAndConnect(globalTag, args)
         
         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()
 
         addMonitoring(process)
         
         return process
 
 

def Reco.Reco.skimming	(	self,
		skims,
		globalTag,
		options
	)

_skimming_

skimming method overload for the prompt skiming

Definition at line 325 of file Reco.py.

     def skimming(self, skims, globalTag,**options):
         """
         _skimming_
 
         skimming method overload for the prompt skiming
         
         """
         options = defaultOptions
         options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
         options.step = "SKIM:"+('+'.join(skims))
         options.name = "SKIM"
         options.conditions = gtNameAndConnect(globalTag, args)
         process = cms.Process("SKIM", self.eras)
         process.source = cms.Source("PoolSource")
 
         if 'customs' in args:
             options.customisation_file=args['customs']
 
         configBuilder = ConfigBuilder(options, process = process)
         configBuilder.prepare()
 
         return process
         

def Reco.Reco.visualizationProcessing	(	self,
		globalTag,
		args
	)

_visualizationProcessing_

Definition at line 148 of file Reco.py.

     def visualizationProcessing(self, globalTag, **args):
         """
         _visualizationProcessing_
 
         """
 
         options = Options()
         options.__dict__.update(defaultOptions.__dict__)
         options.scenario = self.cbSc
         # FIXME: do we need L1Reco here?
         options.step =''
         if 'preFilter' in args:
             options.step +='FILTER:'+args['preFilter']+','
 
         eiStep=''
         if self.cbSc == 'pp':
             eiStep=',EI'
 
         options.step += 'RAW2DIGI,L1Reco,RECO'+eiStep+',ENDJOB'
 
 
         dictIO(options,args)
         options.conditions = gtNameAndConnect(globalTag, args)
         options.timeoutOutput = True
         # FIXME: maybe can go...maybe not
         options.filein = 'tobeoverwritten.xyz'
 
         if 'inputSource' in args:
             options.filetype = args['inputSource']
         else:
             # this is the default as this is what is needed on the OnlineCluster
             options.filetype = 'DQMDAQ'
 
         print "Using %s source"%options.filetype            
 
         process = cms.Process('RECO', cms.ModifierChain(self.eras, self.visModifiers) )
 
         if 'customs' in args:
             options.customisation_file=args['customs']
 
         self._checkRepackedFlag(options, **args)
 
         cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
 
         cb.prepare()
 
 
         
 
         # FIXME: not sure abou this one...drop for the moment
         # addMonitoring(process)
                 
         return process
 
 
 
 