Public Member Functions | |
def | __init__ |
def | addExpressOutputModules |
def | alcaHarvesting |
def | alcaReco |
def | alcaSkim |
def | dqmHarvesting |
def | dropOutputModule |
def | expressProcessing |
def | merge |
def | promptReco |
def | skimming |
_Scenario_
Definition at line 19 of file Scenario.py.
def Scenario.Scenario.__init__ | ( | self | ) |
Definition at line 24 of file Scenario.py.
def Scenario.Scenario.addExpressOutputModules | ( | self, | |
process, | |||
tiers, | |||
datasets | |||
) |
_addExpressOutputModules_ Util method to unpack and install the set of data tier output modules corresponding to the list of tiers and datasets provided
Definition at line 168 of file Scenario.py.
def Scenario.Scenario.alcaHarvesting | ( | self, | |
globalTag, | |||
datasetName, | |||
options | |||
) |
_alcaHarvesting_ build an AlCa Harvesting configuration Arguments: globalTag - The global tag being used inputFiles - The list of LFNs being harvested
Definition at line 112 of file Scenario.py.
def Scenario.Scenario.alcaReco | ( | self, | |
skims, | |||
options | |||
) |
_alcaSkim_ Given a skeleton process install the skim production for given skims
Definition at line 80 of file Scenario.py.
def Scenario.Scenario.alcaSkim | ( | self, | |
skims, | |||
options | |||
) |
_alcaSkim_ Given a skeleton process install the skim splitting for given skims
Definition at line 68 of file Scenario.py.
def Scenario.Scenario.dqmHarvesting | ( | self, | |
datasetName, | |||
runNumber, | |||
globalTag, | |||
options | |||
) |
_dqmHarvesting_ build a DQM Harvesting configuration Arguments: datasetName - aka workflow name for DQMServer, this is the name of the dataset containing the harvested run runNumber - The run being harvested globalTag - The global tag being used inputFiles - The list of LFNs being harvested
Definition at line 92 of file Scenario.py.
def Scenario.Scenario.dropOutputModule | ( | self, | |
processRef, | |||
moduleName | |||
) |
_dropOutputModule_ Util to prune an unwanted output module
Definition at line 157 of file Scenario.py.
Referenced by Impl.preprodmc.preprodmc.alcaReco(), Impl.relvalmcfs.relvalmcfs.alcaReco(), Impl.relvalmc.relvalmc.alcaReco(), and Impl.prodmc.prodmc.alcaReco().
def Scenario.Scenario.expressProcessing | ( | self, | |
globalTag, | |||
writeTiers = [] , |
|||
options | |||
) |
_expressProcessing_ Build an express processing configuration for this scenario. Express processing runs conversion, reco and alca reco on each streamer file in the express stream and writes out RAW, RECO and a combined ALCA file that gets mergepacked in a later step writeTiers is list of tiers to write out, not including ALCA datasets is the list of datasets to split into for each tier written out. Should always be one dataset alcaDataset - if set, this means the combined Alca file is written out with no dataset splitting, it gets assigned straight to the datase provided
Definition at line 43 of file Scenario.py.
def Scenario.Scenario.merge | ( | self, | |
inputFiles, | |||
options | |||
) |
_merge_ builds a merge configuration
Definition at line 142 of file Scenario.py.
References Merge.mergeProcess().
def Scenario.Scenario.promptReco | ( | self, | |
globalTag, | |||
writeTiers = ['RECO'] , |
|||
options | |||
) |
_installPromptReco_ given a skeleton process object and references to the output modules for the products it produces, install the standard reco sequences and event content for this scenario
Definition at line 28 of file Scenario.py.
def Scenario.Scenario.skimming | ( | self, | |
skims, | |||
options | |||
) |
_skimming_ Given a process install the sequences for Tier 1 skimming and the appropriate output modules
Definition at line 129 of file Scenario.py.