Impl.AlCa.AlCa Class Reference

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.

References 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_2017.hcalnzsEra_Run2_2017.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.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_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_2017_trackingLowPU.ppEra_Run2_2017_trackingLowPU.eras, Impl.ppEra_Run2_2017.ppEra_Run2_2017.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Scenario.Scenario.eras, options.HLTProcessOptions.eras, ALCARECOTkAlBeamHalo_cff.filter, and join().

    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.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_2017.hcalnzsEra_Run2_2017.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.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, 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_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.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.

References Utils.dictIO(), 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_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, Impl.ppEra_Run2_2017.ppEra_Run2_2017.eras, Scenario.Scenario.eras, options.HLTProcessOptions.eras, Utils.gtNameAndConnect(), Impl.AlCaPhiSymEcal.AlCaPhiSymEcal.skims, Impl.AlCaTestEnable.AlCaTestEnable.skims, Impl.AlCaP0.AlCaP0.skims, Impl.AlCaLumiPixels.AlCaLumiPixels.skims, and Utils.stepALCAPRODUCER().

    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

---

Generated for CMSSW Reference Manual by  1.8.11