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

Public Member Functions

def __init__
 
def alcaHarvesting
 
def alcaSkim
 
def dqmHarvesting
 
def expressProcessing
 
def promptReco
 
def skimming
 

Public Attributes

 cbSc
 
 recoSeq
 

Detailed Description

Definition at line 17 of file Reco.py.

Constructor & Destructor Documentation

def Reco.Reco.__init__ (   self)

Definition at line 18 of file Reco.py.

18 
19  def __init__(self):
20  self.recoSeq=''
self.cbSc=self.__class__.__name__
Reco.Reco.__init__
def __init__
Definition: Reco.py:18
Reco.Reco.recoSeq
recoSeq
Definition: Reco.py:19
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20

Member Function Documentation

def Reco.Reco.alcaHarvesting (   self,
  globalTag,
  datasetName,
  args 
) 
_alcaHarvesting_

Proton collisions data taking AlCa Harvesting

Definition at line 155 of file Reco.py.

References Impl.hcalnzs.hcalnzs.cbSc, Reco.Reco.cbSc, and join().

155 
156  def alcaHarvesting(self, globalTag, datasetName, **args):
157  """
158  _alcaHarvesting_
159 
160  Proton collisions data taking AlCa Harvesting
161 
162  """
163  if not 'skims' in args: return None
164  options = defaultOptions
165  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
166  options.step = "ALCAHARVEST:"+('+'.join(args['skims']))
167  options.name = "ALCAHARVEST"
168  options.conditions = globalTag
169 
170  process = cms.Process("ALCAHARVEST")
171  process.source = cms.Source("PoolSource")
172  configBuilder = ConfigBuilder(options, process = process)
173  configBuilder.prepare()
174 
175  #
176  # customise process for particular job
177  #
178  process.source.processingMode = cms.untracked.string('RunsAndLumis')
179  process.source.fileNames = cms.untracked(cms.vstring())
180  process.maxEvents.input = -1
181  process.dqmSaver.workflow = datasetName
182 
183  return process
Reco.Reco.alcaHarvesting
def alcaHarvesting
Definition: Reco.py:155
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20
def Reco.Reco.alcaSkim (   self,
  skims,
  args 
) 
_alcaSkim_

AlcaReco processing & skims for proton collisions

Definition at line 89 of file Reco.py.

References Impl.hcalnzs.hcalnzs.cbSc, Reco.Reco.cbSc, and join().

89 
90  def alcaSkim(self, skims, **args):
91  """
92  _alcaSkim_
93 
94  AlcaReco processing & skims for proton collisions
95 
96  """
97 
98  step = ""
99  if 'PromptCalibProd' in skims:
100  step = "ALCA:PromptCalibProd"
101  skims.remove('PromptCalibProd')
102 
103  if len( skims ) > 0:
104  if step != "":
105  step += ","
106  step += "ALCAOUTPUT:"+('+'.join(skims))
107 
108  options = Options()
109  options.__dict__.update(defaultOptions.__dict__)
110  options.scenario = self.cbSc
111  options.step = step
112  options.conditions = args['globaltag'] if 'globaltag' in args else 'None'
113  options.triggerResultsProcess = 'RECO'
114 
115  process = cms.Process('ALCA')
116  cb = ConfigBuilder(options, process = process)
117 
118  # Input source
119  process.source = cms.Source(
120  "PoolSource",
121  fileNames = cms.untracked.vstring()
122  )
123 
124  cb.prepare()
125 
126  # FIXME: dirty hack..any way around this?
127  # Tier0 needs the dataset used for ALCAHARVEST step to be a different data-tier
128  if 'PromptCalibProd' in step:
129  process.ALCARECOStreamPromptCalibProd.dataset.dataTier = cms.untracked.string('ALCAPROMPT')
130 
131  return process
132 
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.alcaSkim
def alcaSkim
Definition: Reco.py:89
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20
def Reco.Reco.dqmHarvesting (   self,
  datasetName,
  runNumber,
  globalTag,
  args 
) 
_dqmHarvesting_

Proton collisions data taking DQM Harvesting

Definition at line 133 of file Reco.py.

References Impl.hcalnzs.hcalnzs.cbSc, Reco.Reco.cbSc, Utils.dqmIOSource(), Utils.dqmSeq(), and Utils.harvestingMode().

133 
134  def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
135  """
136  _dqmHarvesting_
137 
138  Proton collisions data taking DQM Harvesting
139 
140  """
141  options = defaultOptions
142  options.scenario = self.cbSc
143  options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
144  options.name = "EDMtoMEConvert"
145  options.conditions = globalTag
146 
147  process = cms.Process("HARVESTING")
148  process.source = dqmIOSource(args)
149  configBuilder = ConfigBuilder(options, process = process)
150  configBuilder.prepare()
151 
152  harvestingMode(process,datasetName,args,rANDl=False)
153  return process
154 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:116
Reco.Reco.dqmHarvesting
def dqmHarvesting
Definition: Reco.py:133
Utils.dqmIOSource
def dqmIOSource
Definition: Utils.py:88
Utils.harvestingMode
def harvestingMode
Definition: Utils.py:99
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20
def Reco.Reco.expressProcessing (   self,
  globalTag,
  args 
) 
_expressProcessing_

Proton collision data taking express processing

Definition at line 59 of file Reco.py.

References Utils.addMonitoring(), Impl.hcalnzs.hcalnzs.cbSc, Reco.Reco.cbSc, Utils.dictIO(), Utils.dqmSeq(), and Utils.stepALCAPRODUCER().

59 
60  def expressProcessing(self, globalTag, **args):
61  """
62  _expressProcessing_
63 
64  Proton collision data taking express processing
65 
66  """
67  step = stepALCAPRODUCER(args['skims'])
68  dqmStep= dqmSeq(args,'')
69  options = Options()
70  options.__dict__.update(defaultOptions.__dict__)
71  options.scenario = self.cbSc
72  options.step = 'RAW2DIGI,L1Reco,RECO'+step+',DQM'+dqmStep+',ENDJOB'
73  dictIO(options,args)
74  options.conditions = globalTag
75 
76  process = cms.Process('RECO')
77  cb = ConfigBuilder(options, process = process, with_output = True)
78 
79  # Input source
80  process.source = cms.Source("NewEventStreamFileReader",
81  fileNames = cms.untracked.vstring()
82  )
83  cb.prepare()
84 
85  addMonitoring(process)
86 
87  return process
88 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:116
Utils.stepALCAPRODUCER
def stepALCAPRODUCER
Definition: Utils.py:9
Utils.addMonitoring
def addMonitoring
Definition: Utils.py:23
Utils.dictIO
def dictIO
Definition: Utils.py:108
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20
Reco.Reco.expressProcessing
def expressProcessing
Definition: Reco.py:59
def Reco.Reco.promptReco (   self,
  globalTag,
  args 
) 
_promptReco_

Proton collision data taking prompt reco

Definition at line 29 of file Reco.py.

References Utils.addMonitoring(), Impl.hcalnzs.hcalnzs.cbSc, Reco.Reco.cbSc, Utils.dictIO(), Utils.dqmSeq(), Impl.hcalnzs.hcalnzs.recoSeq, Reco.Reco.recoSeq, and Utils.stepALCAPRODUCER().

29 
30  def promptReco(self, globalTag, **args):
31  """
32  _promptReco_
33 
34  Proton collision data taking prompt reco
35 
36  """
37  step = stepALCAPRODUCER(args['skims'])
38  dqmStep= dqmSeq(args,'')
39  options = Options()
40  options.__dict__.update(defaultOptions.__dict__)
41  options.scenario = self.cbSc
42  options.step = 'RAW2DIGI,L1Reco,RECO'+self.recoSeq+step+',DQM'+dqmStep+',ENDJOB'
43  dictIO(options,args)
44  options.conditions = globalTag
45 
46  process = cms.Process('RECO')
47  cb = ConfigBuilder(options, process = process, with_output = True)
48 
49  # Input source
50  process.source = cms.Source("PoolSource",
51  fileNames = cms.untracked.vstring()
52  )
53  cb.prepare()
54 
55  addMonitoring(process)
56 
57  return process
58 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:116
Utils.stepALCAPRODUCER
def stepALCAPRODUCER
Definition: Utils.py:9
Utils.addMonitoring
def addMonitoring
Definition: Utils.py:23
Reco.Reco.promptReco
def promptReco
Definition: Reco.py:29
Utils.dictIO
def dictIO
Definition: Utils.py:108
Reco.Reco.recoSeq
recoSeq
Definition: Reco.py:19
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20
def Reco.Reco.skimming (   self,
  skims,
  globalTag,
  options 
) 
_skimming_

skimming method overload for the prompt skiming

Definition at line 184 of file Reco.py.

References Impl.hcalnzs.hcalnzs.cbSc, Reco.Reco.cbSc, and join().

184 
185  def skimming(self, skims, globalTag,**options):
186  """
187  _skimming_
188 
189  skimming method overload for the prompt skiming
190 
191  """
192  options = defaultOptions
193  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
194  options.step = "SKIM:"+('+'.join(skims))
195  options.name = "SKIM"
196  options.conditions = globalTag
197  process = cms.Process("SKIM")
198  process.source = cms.Source("PoolSource")
199  configBuilder = ConfigBuilder(options, process = process)
200  configBuilder.prepare()
201 
202  return process
Reco.Reco.skimming
def skimming
Definition: Reco.py:184
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20

Member Data Documentation

Reco.Reco.cbSc

Definition at line 20 of file Reco.py.

Referenced by Reco.Reco.alcaHarvesting(), Reco.Reco.alcaSkim(), Reco.Reco.dqmHarvesting(), Reco.Reco.expressProcessing(), Reco.Reco.promptReco(), and Reco.Reco.skimming().

Reco.Reco.recoSeq

Definition at line 19 of file Reco.py.

Referenced by Reco.Reco.promptReco().

Generated for CMSSW Reference Manual by doxygen 1.8.5