List of all members.
Detailed Description
Definition at line 20 of file Scenario.py.
Constructor & Destructor Documentation
def Scenario::Scenario::__init__ |
( |
|
self | ) |
|
Member Function Documentation
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 113 of file Scenario.py.
00114 :
00115 """
00116 _alcaHarvesting_
00117
00118 build an AlCa Harvesting configuration
00119
00120 Arguments:
00121
00122 globalTag - The global tag being used
00123 inputFiles - The list of LFNs being harvested
00124
00125 """
00126 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00127 msg += "Does not contain an implementation for alcaHarvesting"
00128 raise NotImplementedError, msg
00129
def Scenario::Scenario::alcaReco |
( |
|
self, |
|
|
|
skims, |
|
|
|
options |
|
) |
| |
_alcaSkim_
Given a skeleton process install the skim production for given skims
Definition at line 81 of file Scenario.py.
00082 :
00083 """
00084 _alcaSkim_
00085
00086 Given a skeleton process install the skim production for given skims
00087
00088 """
00089 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00090 msg += "Does not contain an implementation for alcaReco"
00091 raise NotImplementedError, msg
00092
def Scenario::Scenario::alcaSkim |
( |
|
self, |
|
|
|
skims, |
|
|
|
options |
|
) |
| |
_alcaSkim_
Given a skeleton process install the skim splitting for given skims
Definition at line 69 of file Scenario.py.
00070 :
00071 """
00072 _alcaSkim_
00073
00074 Given a skeleton process install the skim splitting for given skims
00075
00076 """
00077 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00078 msg += "Does not contain an implementation for alcaSkim"
00079 raise NotImplementedError, msg
00080
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 93 of file Scenario.py.
00094 :
00095 """
00096 _dqmHarvesting_
00097
00098 build a DQM Harvesting configuration
00099
00100 Arguments:
00101
00102 datasetName - aka workflow name for DQMServer, this is the name of the
00103 dataset containing the harvested run
00104 runNumber - The run being harvested
00105 globalTag - The global tag being used
00106 inputFiles - The list of LFNs being harvested
00107
00108 """
00109 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00110 msg += "Does not contain an implementation for dqmHarvesting"
00111 raise NotImplementedError, msg
00112
def Scenario::Scenario::dropOutputModule |
( |
|
self, |
|
|
|
processRef, |
|
|
|
moduleName |
|
) |
| |
_dropOutputModule_
Util to prune an unwanted output module
Definition at line 169 of file Scenario.py.
00170 :
00171 """
00172 _dropOutputModule_
00173
00174 Util to prune an unwanted output module
00175
00176 """
00177 del process._Process__outputmodules[moduleName]
00178 return
def Scenario::Scenario::expressProcessing |
( |
|
self, |
|
|
|
globalTag, |
|
|
|
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 44 of file Scenario.py.
00045 :
00046 """
00047 _expressProcessing_
00048
00049 Build an express processing configuration for this scenario.
00050
00051 Express processing runs conversion, reco and alca reco on each
00052 streamer file in the express stream and writes out RAW, RECO and
00053 a combined ALCA file that gets mergepacked in a later step
00054
00055 writeTiers is list of tiers to write out, not including ALCA
00056
00057 datasets is the list of datasets to split into for each tier
00058 written out. Should always be one dataset
00059
00060 alcaDataset - if set, this means the combined Alca file is written
00061 out with no dataset splitting, it gets assigned straight to the datase
00062 provided
00063
00064 """
00065 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00066 msg += "Does not contain an implementation for expressProcessing"
00067 raise NotImplementedError, msg
00068
def Scenario::Scenario::merge |
( |
|
self, |
|
|
|
inputFiles, |
|
|
|
options |
|
) |
| |
_merge_
builds a merge configuration
Definition at line 143 of file Scenario.py.
00144 :
00145 """
00146 _merge_
00147
00148 builds a merge configuration
00149
00150 """
00151 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00152 return mergeProcess(*inputFiles, **options)
00153
def Scenario::Scenario::promptReco |
( |
|
self, |
|
|
|
globalTag, |
|
|
|
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 29 of file Scenario.py.
00030 :
00031 """
00032 _installPromptReco_
00033
00034 given a skeleton process object and references
00035 to the output modules for the products it produces,
00036 install the standard reco sequences and event content for this
00037 scenario
00038
00039 """
00040 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00041 msg += "Does not contain an implementation for promptReco"
00042 raise NotImplementedError, msg
00043
def Scenario::Scenario::repack |
( |
|
self, |
|
|
|
options |
|
) |
| |
_repack_
builds a repack configuration
Definition at line 154 of file Scenario.py.
00155 :
00156 """
00157 _repack_
00158
00159 builds a repack configuration
00160
00161 """
00162 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00163 return repackProcess(**options)
00164
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 130 of file Scenario.py.
00131 :
00132 """
00133 _skimming_
00134
00135 Given a process install the sequences for Tier 1 skimming
00136 and the appropriate output modules
00137
00138 """
00139 msg = "Scenario Implementation %s\n" % self.__class__.__name__
00140 msg += "Does not contain an implementation for skimming"
00141 raise NotImplementedError, msg
00142