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.

     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