CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions
Scenario.Scenario Class Reference
Inheritance diagram for Scenario.Scenario:

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 24 of file Scenario.py.

Constructor & Destructor Documentation

def Scenario.Scenario.__init__ (   self)

Definition at line 29 of file Scenario.py.

29 
30  def __init__(self):
31  pass
32 

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 117 of file Scenario.py.

117 
118  def alcaHarvesting(self, globalTag, datasetName, **options):
119  """
120  _alcaHarvesting_
121 
122  build an AlCa Harvesting configuration
123 
124  Arguments:
125 
126  globalTag - The global tag being used
127  inputFiles - The list of LFNs being harvested
128 
129  """
130  msg = "Scenario Implementation %s\n" % self.__class__.__name__
131  msg += "Does not contain an implementation for alcaHarvesting"
132  raise NotImplementedError, msg
133 
def Scenario.Scenario.alcaReco (   self,
  skims,
  options 
) 
_alcaSkim_

Given a skeleton process install the skim production for given skims

Definition at line 85 of file Scenario.py.

85 
86  def alcaReco(self, *skims, **options):
87  """
88  _alcaSkim_
89 
90  Given a skeleton process install the skim production for given skims
91 
92  """
93  msg = "Scenario Implementation %s\n" % self.__class__.__name__
94  msg += "Does not contain an implementation for alcaReco"
95  raise NotImplementedError, msg
96 
def Scenario.Scenario.alcaSkim (   self,
  skims,
  options 
) 
_alcaSkim_

Given a skeleton process install the skim splitting for given skims

Definition at line 73 of file Scenario.py.

73 
74  def alcaSkim(self, skims, **options):
75  """
76  _alcaSkim_
77 
78  Given a skeleton process install the skim splitting for given skims
79 
80  """
81  msg = "Scenario Implementation %s\n" % self.__class__.__name__
82  msg += "Does not contain an implementation for alcaSkim"
83  raise NotImplementedError, msg
84 
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 97 of file Scenario.py.

97 
98  def dqmHarvesting(self, datasetName, runNumber, globalTag, **options):
99  """
100  _dqmHarvesting_
101 
102  build a DQM Harvesting configuration
103 
104  Arguments:
105 
106  datasetName - aka workflow name for DQMServer, this is the name of the
107  dataset containing the harvested run
108  runNumber - The run being harvested
109  globalTag - The global tag being used
110  inputFiles - The list of LFNs being harvested
111 
112  """
113  msg = "Scenario Implementation %s\n" % self.__class__.__name__
114  msg += "Does not contain an implementation for dqmHarvesting"
115  raise NotImplementedError, msg
116 
def Scenario.Scenario.dropOutputModule (   self,
  processRef,
  moduleName 
) 
_dropOutputModule_

Util to prune an unwanted output module

Definition at line 173 of file Scenario.py.

173 
174  def dropOutputModule(self, processRef, moduleName):
175  """
176  _dropOutputModule_
177 
178  Util to prune an unwanted output module
179 
180  """
181  del process._Process__outputmodules[moduleName]
182  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 48 of file Scenario.py.

48 
49  def expressProcessing(self, globalTag, **options):
50  """
51  _expressProcessing_
52 
53  Build an express processing configuration for this scenario.
54 
55  Express processing runs conversion, reco and alca reco on each
56  streamer file in the express stream and writes out RAW, RECO and
57  a combined ALCA file that gets mergepacked in a later step
58 
59  writeTiers is list of tiers to write out, not including ALCA
60 
61  datasets is the list of datasets to split into for each tier
62  written out. Should always be one dataset
63 
64  alcaDataset - if set, this means the combined Alca file is written
65  out with no dataset splitting, it gets assigned straight to the datase
66  provided
67 
68  """
69  msg = "Scenario Implementation %s\n" % self.__class__.__name__
70  msg += "Does not contain an implementation for expressProcessing"
71  raise NotImplementedError, msg
72 
Scenario.Scenario.expressProcessing
def expressProcessing
Definition: Scenario.py:48
def Scenario.Scenario.merge (   self,
  inputFiles,
  options 
) 
_merge_

builds a merge configuration

Definition at line 147 of file Scenario.py.

References Merge.mergeProcess().

147 
148  def merge(self, *inputFiles, **options):
149  """
150  _merge_
151 
152  builds a merge configuration
153 
154  """
155  msg = "Scenario Implementation %s\n" % self.__class__.__name__
156  return mergeProcess(*inputFiles, **options)
157 
Merge.mergeProcess
def mergeProcess
Definition: Merge.py:16
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 33 of file Scenario.py.

33 
34  def promptReco(self, globalTag, **options):
35  """
36  _installPromptReco_
37 
38  given a skeleton process object and references
39  to the output modules for the products it produces,
40  install the standard reco sequences and event content for this
41  scenario
42 
43  """
44  msg = "Scenario Implementation %s\n" % self.__class__.__name__
45  msg += "Does not contain an implementation for promptReco"
46  raise NotImplementedError, msg
47 
def Scenario.Scenario.repack (   self,
  options 
) 
_repack_

builds a repack configuration

Definition at line 158 of file Scenario.py.

References Repack.repackProcess().

158 
159  def repack(self, **options):
160  """
161  _repack_
162 
163  builds a repack configuration
164 
165  """
166  msg = "Scenario Implementation %s\n" % self.__class__.__name__
167  return repackProcess(**options)
168 
Repack.repackProcess
def repackProcess
Definition: Repack.py:12
def Scenario.Scenario.skimming (   self,
  skims,
  globalTag,
  options 
) 
_skimming_

Given a process install the sequences for Tier 1 skimming
and the appropriate output modules

Definition at line 134 of file Scenario.py.

134 
135  def skimming(self, skims, globalTag, **options):
136  """
137  _skimming_
138 
139  Given a process install the sequences for Tier 1 skimming
140  and the appropriate output modules
141 
142  """
143  msg = "Scenario Implementation %s\n" % self.__class__.__name__
144  msg += "Does not contain an implementation for skimming"
145  raise NotImplementedError, msg
146 
Generated for CMSSW Reference Manual by doxygen 1.8.5