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
	addEI

	cbSc

	expressModifiers

	promptModifiers

	recoSeq

	visModifiers

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

Detailed Description

Definition at line 18 of file Reco.py.

Constructor & Destructor Documentation

◆ init()

def Reco.Reco.__init__ ( self )

Definition at line 19 of file Reco.py.

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

Member Function Documentation

◆ _checkRepackedFlag()

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

private

Definition at line 36 of file Reco.py.

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

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

◆ alcaHarvesting()

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

_alcaHarvesting_

Proton collisions data taking AlCa Harvesting

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

◆ alcaSkim()

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

_alcaSkim_

AlcaReco processing & skims for proton collisions

Definition at line 211 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 = [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 = 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
  
  

◆ dqmHarvesting()

def Reco.Reco.dqmHarvesting	(		self,
			datasetName,
			runNumber,
			globalTag,
		**	args
	)

_dqmHarvesting_

Proton collisions data taking DQM Harvesting

Definition at line 264 of file Reco.py.

     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
  
  

◆ expressProcessing()

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

_expressProcessing_

Proton collision data taking express processing

Definition at line 104 of file Reco.py.

     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
         if ('nThreads' in args) :
             options.nThreads=args['nThreads']
  
         eiStep=''
         if self.addEI:
             eiStep=',EI'
  
         options.step = 'RAW2DIGI,L1Reco,RECO'+self.recoSeq+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
  
  

◆ promptReco()

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

_promptReco_

Proton collision data taking prompt reco

Definition at line 45 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
         if ('nThreads' in args) :
             options.nThreads=args['nThreads']
  
         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.addEI:
             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
  
  

◆ skimming()

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

_skimming_

skimming method overload for the prompt skiming

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

◆ visualizationProcessing()

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

_visualizationProcessing_

Definition at line 154 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.addEI:
             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
  
  
  
  

Member Data Documentation

◆ addEI

Reco.Reco.addEI

Definition at line 22 of file Reco.py.

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

◆ cbSc

Reco.Reco.cbSc

Definition at line 23 of file Reco.py.

Referenced by Impl.AlCa.AlCa.alcaHarvesting(), Reco.Reco.alcaHarvesting(), Reco.Reco.alcaSkim(), Reco.Reco.dqmHarvesting(), Reco.Reco.expressProcessing(), Reco.Reco.promptReco(), Reco.Reco.skimming(), and Reco.Reco.visualizationProcessing().

◆ expressModifiers

Reco.Reco.expressModifiers

Definition at line 25 of file Reco.py.

Referenced by Reco.Reco.expressProcessing().

◆ promptModifiers

Reco.Reco.promptModifiers

Definition at line 24 of file Reco.py.

Referenced by Reco.Reco.promptReco().

◆ recoSeq

Reco.Reco.recoSeq

Definition at line 21 of file Reco.py.

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

◆ visModifiers

Reco.Reco.visModifiers

Definition at line 26 of file Reco.py.

Referenced by Reco.Reco.visualizationProcessing().

Public Member Functions

Public Attributes

Private Member Functions