Public Member Functions
def	__init__
def	alcaHarvesting
def	alcaReco
def	alcaSkim
def	dqmHarvesting
def	dropOutputModule
def	expressProcessing
def	merge
def	promptReco
def	repack
def	skimming

Detailed Description

_Scenario_

Definition at line 20 of file Scenario.py.

Constructor & Destructor Documentation

def Scenario::Scenario::__init__ ( self )

Definition at line 25 of file Scenario.py.

00026                       :
00027         pass
00028

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

Scenario::Scenario Class Reference

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation