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
 
def visualizationProcessing
 

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 210 of file Reco.py.

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

210 
211  def alcaHarvesting(self, globalTag, datasetName, **args):
212  """
213  _alcaHarvesting_
214 
215  Proton collisions data taking AlCa Harvesting
216 
217  """
218  if not 'skims' in args: return None
219  options = defaultOptions
220  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
221  options.step = "ALCAHARVEST:"+('+'.join(args['skims']))
222  options.name = "ALCAHARVEST"
223  options.conditions = globalTag
224 
225  process = cms.Process("ALCAHARVEST")
226  process.source = cms.Source("PoolSource")
227  configBuilder = ConfigBuilder(options, process = process)
228  configBuilder.prepare()
229 
230  #
231  # customise process for particular job
232  #
233  process.source.processingMode = cms.untracked.string('RunsAndLumis')
234  process.source.fileNames = cms.untracked(cms.vstring())
235  process.maxEvents.input = -1
236  process.dqmSaver.workflow = datasetName
237 
238  return process
Reco.Reco.alcaHarvesting
def alcaHarvesting
Definition: Reco.py:210
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 140 of file Reco.py.

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

140 
141  def alcaSkim(self, skims, **args):
142  """
143  _alcaSkim_
144 
145  AlcaReco processing & skims for proton collisions
146 
147  """
148 
149  step = ""
150  pclWflws = [x for x in skims if "PromptCalibProd" in x]
151  if len(pclWflws):
152  step = 'ALCA:'
153  for wfl in pclWflws:
154  step += wfl
155  skims.remove(wfl)
156 
157  if len( skims ) > 0:
158  if step != "":
159  step += ","
160  step += "ALCAOUTPUT:"+('+'.join(skims))
161 
162  options = Options()
163  options.__dict__.update(defaultOptions.__dict__)
164  options.scenario = self.cbSc
165  options.step = step
166  options.conditions = args['globaltag'] if 'globaltag' in args else 'None'
167  options.triggerResultsProcess = 'RECO'
168 
169  process = cms.Process('ALCA')
170  cb = ConfigBuilder(options, process = process)
171 
172  # Input source
173  process.source = cms.Source(
174  "PoolSource",
175  fileNames = cms.untracked.vstring()
176  )
177 
178  cb.prepare()
179 
180  # FIXME: dirty hack..any way around this?
181  # Tier0 needs the dataset used for ALCAHARVEST step to be a different data-tier
182  for wfl in pclWflws:
183  methodToCall = getattr(process, 'ALCARECOStream'+wfl)
184  methodToCall.dataset.dataTier = cms.untracked.string('ALCAPROMPT')
185 
186  return process
187 
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.alcaSkim
def alcaSkim
Definition: Reco.py:140
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 188 of file Reco.py.

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

188 
189  def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
190  """
191  _dqmHarvesting_
192 
193  Proton collisions data taking DQM Harvesting
194 
195  """
196  options = defaultOptions
197  options.scenario = self.cbSc
198  options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
199  options.name = "EDMtoMEConvert"
200  options.conditions = globalTag
201 
202  process = cms.Process("HARVESTING")
203  process.source = dqmIOSource(args)
204  configBuilder = ConfigBuilder(options, process = process)
205  configBuilder.prepare()
206 
207  harvestingMode(process,datasetName,args,rANDl=False)
208  return process
209 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:116
Reco.Reco.dqmHarvesting
def dqmHarvesting
Definition: Reco.py:188
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.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2.ppRun2.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  skims = args['skims']
68  # the AlCaReco skims for PCL should only run during AlCaSkimming step which uses the same configuration on the Tier0 side, for this reason we drop them here
69  pclWkflws = [x for x in skims if "PromptCalibProd" in x]
70  for wfl in pclWkflws:
71  skims.remove(wfl)
72 
73  step = stepALCAPRODUCER(skims)
74  dqmStep= dqmSeq(args,'')
75  options = Options()
76  options.__dict__.update(defaultOptions.__dict__)
77  options.scenario = self.cbSc
78  options.step = 'RAW2DIGI,L1Reco,RECO'+step+',DQM'+dqmStep+',ENDJOB'
79  dictIO(options,args)
80  options.conditions = globalTag
81  options.filein = 'tobeoverwritten.xyz'
82  if 'inputSource' in args:
83  options.fileType = args['inputSource']
84  process = cms.Process('RECO')
85  cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
86 
87  cb.prepare()
88 
89  addMonitoring(process)
90 
91  return process
92 
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, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.ppRun2.ppRun2.cbSc, Reco.Reco.cbSc, Utils.dictIO(), Utils.dqmSeq(), Impl.hcalnzs.hcalnzs.recoSeq, Impl.cosmicsRun2.cosmicsRun2.recoSeq, Impl.ppRun2.ppRun2.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 239 of file Reco.py.

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

239 
240  def skimming(self, skims, globalTag,**options):
241  """
242  _skimming_
243 
244  skimming method overload for the prompt skiming
245 
246  """
247  options = defaultOptions
248  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
249  options.step = "SKIM:"+('+'.join(skims))
250  options.name = "SKIM"
251  options.conditions = globalTag
252  process = cms.Process("SKIM")
253  process.source = cms.Source("PoolSource")
254  configBuilder = ConfigBuilder(options, process = process)
255  configBuilder.prepare()
256 
257  return process
Reco.Reco.skimming
def skimming
Definition: Reco.py:239
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.cbSc
cbSc
Definition: Reco.py:20
def Reco.Reco.visualizationProcessing (   self,
  globalTag,
  args 
) 
_visualizationProcessing_

Definition at line 93 of file Reco.py.

References Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2.ppRun2.cbSc, Reco.Reco.cbSc, and Utils.dictIO().

93 
94  def visualizationProcessing(self, globalTag, **args):
95  """
96  _visualizationProcessing_
97 
98  """
99 
100  options = Options()
101  options.__dict__.update(defaultOptions.__dict__)
102  options.scenario = self.cbSc
103  # FIXME: do we need L1Reco here?
104  options.step =''
105  if 'preFilter' in args:
106  options.step +='FILTER:'+args['preFilter']+','
107 
108  options.step += 'RAW2DIGI,L1Reco,RECO,ENDJOB'
109 
110 
111  dictIO(options,args)
112  options.conditions = globalTag
113  options.timeoutOutput = True
114  # FIXME: maybe can go...maybe not
115  options.filein = 'tobeoverwritten.xyz'
116 
117  if 'inputSource' in args:
118  options.filetype = args['inputSource']
119  else:
120  # this is the default as this is what is needed on the OnlineCluster
121  options.filetype = 'DQMDAQ'
122 
123  print "Using %s source"%options.filetype
124 
125  process = cms.Process('RECO')
126  cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
127 
128  cb.prepare()
129 
130 
131 
132 
133  # FIXME: not sure abou this one...drop for the moment
134  # addMonitoring(process)
135 
136  return process
137 
138 
139 
Reco.Reco.visualizationProcessing
def visualizationProcessing
Definition: Reco.py:93
Utils.dictIO
def dictIO
Definition: Utils.py:108
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(), Reco.Reco.skimming(), and Reco.Reco.visualizationProcessing().

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