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 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.alcaHarvesting	(	self,
		globalTag,
		datasetName,
		args
	)

_alcaHarvesting_

Proton collisions data taking AlCa Harvesting

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

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.

     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.expressProcessing	(	self,
		globalTag,
		args
	)

_expressProcessing_

Proton collision data taking express processing

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

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