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

Constructor & Destructor Documentation

def Scenario.Scenario.__init__ (   self)

Definition at line 25 of file Scenario.py.

25 
26  def __init__(self):
27  pass
28 

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.

113 
114  def alcaHarvesting(self, globalTag, datasetName, **options):
115  """
116  _alcaHarvesting_
117 
118  build an AlCa Harvesting configuration
119 
120  Arguments:
121 
122  globalTag - The global tag being used
123  inputFiles - The list of LFNs being harvested
124 
125  """
126  msg = "Scenario Implementation %s\n" % self.__class__.__name__
127  msg += "Does not contain an implementation for alcaHarvesting"
128  raise NotImplementedError, msg
129 
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.

81 
82  def alcaReco(self, *skims, **options):
83  """
84  _alcaSkim_
85 
86  Given a skeleton process install the skim production for given skims
87 
88  """
89  msg = "Scenario Implementation %s\n" % self.__class__.__name__
90  msg += "Does not contain an implementation for alcaReco"
91  raise NotImplementedError, msg
92 
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.

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

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

Util to prune an unwanted output module

Definition at line 169 of file Scenario.py.

169 
170  def dropOutputModule(self, processRef, moduleName):
171  """
172  _dropOutputModule_
173 
174  Util to prune an unwanted output module
175 
176  """
177  del process._Process__outputmodules[moduleName]
178  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.

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

builds a merge configuration

Definition at line 143 of file Scenario.py.

References Merge.mergeProcess().

143 
144  def merge(self, *inputFiles, **options):
145  """
146  _merge_
147 
148  builds a merge configuration
149 
150  """
151  msg = "Scenario Implementation %s\n" % self.__class__.__name__
152  return mergeProcess(*inputFiles, **options)
153 
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 29 of file Scenario.py.

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

builds a repack configuration

Definition at line 154 of file Scenario.py.

References Repack.repackProcess().

154 
155  def repack(self, **options):
156  """
157  _repack_
158 
159  builds a repack configuration
160 
161  """
162  msg = "Scenario Implementation %s\n" % self.__class__.__name__
163  return repackProcess(**options)
164 
Repack.repackProcess
def repackProcess
Definition: Repack.py:12
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.

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