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 | Private Member Functions
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
 
 expressModifiers
 
 promptModifiers
 
 recoSeq
 
 visModifiers
 

Private Member Functions

def _checkRepackedFlag
 

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  Scenario.__init__(self)
21  self.recoSeq=''
22  self.cbSc=self.__class__.__name__
23  self.promptModifiers = cms.ModifierChain()
24  self.expressModifiers = cms.ModifierChain()
self.visModifiers = cms.ModifierChain()
Reco.Reco.visModifiers
visModifiers
Definition: Reco.py:24
Reco.Reco.expressModifiers
expressModifiers
Definition: Reco.py:23
Reco.Reco.__init__
def __init__
Definition: Reco.py:18
Reco.Reco.promptModifiers
promptModifiers
Definition: Reco.py:22
Reco.Reco.recoSeq
recoSeq
Definition: Reco.py:20
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21

Member Function Documentation

def Reco.Reco._checkRepackedFlag (   self,
  options,
  args 
)
private

Definition at line 34 of file Reco.py.

Referenced by Reco.Reco.expressProcessing(), Reco.Reco.promptReco(), and Reco.Reco.visualizationProcessing().

34 
35  def _checkRepackedFlag(self, options, **args):
36  if 'repacked' in args:
37  if args['repacked'] == True:
38  options.isRepacked = True
39  else:
40  options.isRepacked = False
41 
42 
Reco.Reco._checkRepackedFlag
def _checkRepackedFlag
Definition: Reco.py:34
def Reco.Reco.alcaHarvesting (   self,
  globalTag,
  datasetName,
  args 
) 
_alcaHarvesting_

Proton collisions data taking AlCa Harvesting

Definition at line 284 of file Reco.py.

References Impl.pplowpu.pplowpu.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.cosmics.cosmics.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.pp.pp.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Reco.Reco.cbSc, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), and join().

284 
285  def alcaHarvesting(self, globalTag, datasetName, **args):
286  """
287  _alcaHarvesting_
288 
289  Proton collisions data taking AlCa Harvesting
290 
291  """
292  skims = []
293  if 'skims' in args:
294  skims = args['skims']
295 
296 
297  if 'alcapromptdataset' in args:
298  skims.append('@'+args['alcapromptdataset'])
299 
300  if len(skims) == 0: return None
301  options = defaultOptions
302  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
303  options.step = "ALCAHARVEST:"+('+'.join(skims))
304  options.name = "ALCAHARVEST"
305  options.conditions = gtNameAndConnect(globalTag, args)
306 
307  process = cms.Process("ALCAHARVEST", self.eras)
308  process.source = cms.Source("PoolSource")
309 
310  if 'customs' in args:
311  options.customisation_file=args['customs']
312 
313  configBuilder = ConfigBuilder(options, process = process)
314  configBuilder.prepare()
315 
316  #
317  # customise process for particular job
318  #
319  process.source.processingMode = cms.untracked.string('RunsAndLumis')
320  process.source.fileNames = cms.untracked(cms.vstring())
321  process.maxEvents.input = -1
322  process.dqmSaver.workflow = datasetName
323 
324  return process
Reco.Reco.alcaHarvesting
def alcaHarvesting
Definition: Reco.py:284
Utils.gtNameAndConnect
def gtNameAndConnect
Definition: Utils.py:137
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21
def Reco.Reco.alcaSkim (   self,
  skims,
  args 
) 
_alcaSkim_

AlcaReco processing & skims for proton collisions

Definition at line 205 of file Reco.py.

References Impl.pplowpu.pplowpu.cbSc, Impl.cosmics.cosmics.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.pp.pp.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Scenario.Scenario.eras, alcazmumu_cfi.filter, and join().

205 
206  def alcaSkim(self, skims, **args):
207  """
208  _alcaSkim_
209 
210  AlcaReco processing & skims for proton collisions
211 
212  """
213 
214  step = ""
215  pclWflws = [x for x in skims if "PromptCalibProd" in x]
216  skims = filter(lambda x: x not in pclWflws, skims)
217 
218  if len(pclWflws):
219  step += 'ALCA:'+('+'.join(pclWflws))
220 
221  if len( skims ) > 0:
222  if step != "":
223  step += ","
224  step += "ALCAOUTPUT:"+('+'.join(skims))
225 
226  options = Options()
227  options.__dict__.update(defaultOptions.__dict__)
228  options.scenario = self.cbSc
229  options.step = step
230  options.conditions = args['globaltag'] if 'globaltag' in args else 'None'
231  if 'globalTagConnect' in args and args['globalTagConnect'] != '':
232  options.conditions += ','+args['globalTagConnect']
233 
234  options.triggerResultsProcess = 'RECO'
235 
236  if 'customs' in args:
237  options.customisation_file=args['customs']
238 
239  process = cms.Process('ALCA', self.eras)
240  cb = ConfigBuilder(options, process = process)
241 
242  # Input source
243  process.source = cms.Source(
244  "PoolSource",
245  fileNames = cms.untracked.vstring()
246  )
247 
248  cb.prepare()
249 
250  # FIXME: dirty hack..any way around this?
251  # Tier0 needs the dataset used for ALCAHARVEST step to be a different data-tier
252  for wfl in pclWflws:
253  methodToCall = getattr(process, 'ALCARECOStream'+wfl)
254  methodToCall.dataset.dataTier = cms.untracked.string('ALCAPROMPT')
255 
256  return process
257 
alcazmumu_cfi.filter
tuple filter
Definition: alcazmumu_cfi.py:34
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.alcaSkim
def alcaSkim
Definition: Reco.py:205
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21
def Reco.Reco.dqmHarvesting (   self,
  datasetName,
  runNumber,
  globalTag,
  args 
) 
_dqmHarvesting_

Proton collisions data taking DQM Harvesting

Definition at line 258 of file Reco.py.

References Impl.pplowpu.pplowpu.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.cosmics.cosmics.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.pp.pp.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Reco.Reco.cbSc, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Utils.dqmIOSource(), Utils.dqmSeq(), Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), and Utils.harvestingMode().

258 
259  def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
260  """
261  _dqmHarvesting_
262 
263  Proton collisions data taking DQM Harvesting
264 
265  """
266  options = defaultOptions
267  options.scenario = self.cbSc
268  options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
269  options.name = "EDMtoMEConvert"
270  options.conditions = gtNameAndConnect(globalTag, args)
271 
272  process = cms.Process("HARVESTING", self.eras)
273  process.source = dqmIOSource(args)
274 
275  if 'customs' in args:
276  options.customisation_file=args['customs']
277 
278  configBuilder = ConfigBuilder(options, process = process)
279  configBuilder.prepare()
280 
281  harvestingMode(process,datasetName,args,rANDl=False)
282  return process
283 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:131
Reco.Reco.dqmHarvesting
def dqmHarvesting
Definition: Reco.py:258
Utils.gtNameAndConnect
def gtNameAndConnect
Definition: Utils.py:137
Utils.dqmIOSource
def dqmIOSource
Definition: Utils.py:103
Utils.harvestingMode
def harvestingMode
Definition: Utils.py:114
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21
def Reco.Reco.expressProcessing (   self,
  globalTag,
  args 
) 
_expressProcessing_

Proton collision data taking express processing

Definition at line 101 of file Reco.py.

References Reco.Reco._checkRepackedFlag(), Utils.addMonitoring(), Impl.pplowpu.pplowpu.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.cosmics.cosmics.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.pp.pp.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Utils.dictIO(), Utils.dqmSeq(), Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Scenario.Scenario.eras, Impl.pp.pp.expressModifiers, Impl.HeavyIons.HeavyIons.expressModifiers, Reco.Reco.expressModifiers, Utils.gtNameAndConnect(), and Utils.stepALCAPRODUCER().

101 
102  def expressProcessing(self, globalTag, **args):
103  """
104  _expressProcessing_
105 
106  Proton collision data taking express processing
107 
108  """
109  skims = args['skims']
110  # 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
111  pclWkflws = [x for x in skims if "PromptCalibProd" in x]
112  for wfl in pclWkflws:
113  skims.remove(wfl)
114 
115  step = stepALCAPRODUCER(skims)
116  dqmStep= dqmSeq(args,'')
117  options = Options()
118  options.__dict__.update(defaultOptions.__dict__)
119  options.scenario = self.cbSc
120 
121  eiStep=''
122  if self.cbSc == 'pp':
123  eiStep=',EI'
124 
125  options.step = 'RAW2DIGI,L1Reco,RECO'+eiStep+step+',DQM'+dqmStep+',ENDJOB'
126  dictIO(options,args)
127  options.conditions = gtNameAndConnect(globalTag, args)
128 
129 
130  options.filein = 'tobeoverwritten.xyz'
131  if 'inputSource' in args:
132  options.filetype = args['inputSource']
133  process = cms.Process('RECO', cms.ModifierChain(self.eras, self.expressModifiers) )
134 
135  if 'customs' in args:
136  options.customisation_file=args['customs']
137 
138  self._checkRepackedFlag(options,**args)
139 
140  cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
141 
142  cb.prepare()
143 
144  addMonitoring(process)
145 
146  return process
147 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:131
Utils.stepALCAPRODUCER
def stepALCAPRODUCER
Definition: Utils.py:9
Reco.Reco.expressModifiers
expressModifiers
Definition: Reco.py:23
Utils.addMonitoring
def addMonitoring
Definition: Utils.py:38
Utils.gtNameAndConnect
def gtNameAndConnect
Definition: Utils.py:137
Utils.dictIO
def dictIO
Definition: Utils.py:123
Reco.Reco._checkRepackedFlag
def _checkRepackedFlag
Definition: Reco.py:34
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21
Reco.Reco.expressProcessing
def expressProcessing
Definition: Reco.py:101
def Reco.Reco.promptReco (   self,
  globalTag,
  args 
) 
_promptReco_

Proton collision data taking prompt reco

Definition at line 43 of file Reco.py.

References Reco.Reco._checkRepackedFlag(), Utils.addMonitoring(), Impl.pplowpu.pplowpu.cbSc, Impl.cosmics.cosmics.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.pp.pp.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Utils.dictIO(), Utils.dqmSeq(), Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), Reco.Reco.promptModifiers, Impl.cosmicsRun2.cosmicsRun2.recoSeq, Impl.cosmics.cosmics.recoSeq, Impl.hcalnzs.hcalnzs.recoSeq, Impl.hcalnzsRun2.hcalnzsRun2.recoSeq, Impl.HeavyIonsRun2.HeavyIonsRun2.recoSeq, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.recoSeq, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.recoSeq, Impl.ppRun2B0T.ppRun2B0T.recoSeq, Impl.ppRun2.ppRun2.recoSeq, Impl.ppRun2at50ns.ppRun2at50ns.recoSeq, Impl.HeavyIons.HeavyIons.recoSeq, Impl.pp.pp.recoSeq, Reco.Reco.recoSeq, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.recoSeq, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.recoSeq, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.recoSeq, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.recoSeq, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.recoSeq, Impl.ppEra_Run2_2016.ppEra_Run2_2016.recoSeq, Utils.stepALCAPRODUCER(), and Utils.stepSKIMPRODUCER().

43 
44  def promptReco(self, globalTag, **args):
45  """
46  _promptReco_
47 
48  Proton collision data taking prompt reco
49 
50  """
51  step = stepALCAPRODUCER(args['skims'])
52  PhysicsSkimStep = ''
53  if ("PhysicsSkims" in args) :
54  PhysicsSkimStep = stepSKIMPRODUCER(args['PhysicsSkims'])
55  dqmStep= dqmSeq(args,'')
56  options = Options()
57  options.__dict__.update(defaultOptions.__dict__)
58  options.scenario = self.cbSc
59 
60  miniAODStep=''
61 
62 # if miniAOD is asked for - then retrieve the miniaod config
63  if 'outputs' in args:
64  for a in args['outputs']:
65  if a['dataTier'] == 'MINIAOD':
66  miniAODStep=',PAT'
67 
68  """
69  Unscheduled for all
70  """
71  options.runUnscheduled=True
72 
73  self._checkRepackedFlag(options, **args)
74 
75  if 'customs' in args:
76  options.customisation_file=args['customs']
77 
78  eiStep=''
79  if self.cbSc == 'pp':
80  eiStep=',EI'
81 
82  options.step = 'RAW2DIGI,L1Reco,RECO'+self.recoSeq+eiStep+step+PhysicsSkimStep+miniAODStep+',DQM'+dqmStep+',ENDJOB'
83 
84 
85  dictIO(options,args)
86  options.conditions = gtNameAndConnect(globalTag, args)
87 
88  process = cms.Process('RECO', cms.ModifierChain(self.eras, self.promptModifiers) )
89  cb = ConfigBuilder(options, process = process, with_output = True)
90 
91  # Input source
92  process.source = cms.Source("PoolSource",
93  fileNames = cms.untracked.vstring()
94  )
95  cb.prepare()
96 
97  addMonitoring(process)
98 
99  return process
100 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:131
Utils.stepALCAPRODUCER
def stepALCAPRODUCER
Definition: Utils.py:9
Utils.addMonitoring
def addMonitoring
Definition: Utils.py:38
Utils.stepSKIMPRODUCER
def stepSKIMPRODUCER
Definition: Utils.py:24
Reco.Reco.promptReco
def promptReco
Definition: Reco.py:43
Reco.Reco.promptModifiers
promptModifiers
Definition: Reco.py:22
Utils.gtNameAndConnect
def gtNameAndConnect
Definition: Utils.py:137
Utils.dictIO
def dictIO
Definition: Utils.py:123
Reco.Reco._checkRepackedFlag
def _checkRepackedFlag
Definition: Reco.py:34
Reco.Reco.recoSeq
recoSeq
Definition: Reco.py:20
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21
def Reco.Reco.skimming (   self,
  skims,
  globalTag,
  options 
) 
_skimming_

skimming method overload for the prompt skiming

Definition at line 325 of file Reco.py.

References Impl.pplowpu.pplowpu.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.cosmics.cosmics.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.pp.pp.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Reco.Reco.cbSc, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), and join().

325 
326  def skimming(self, skims, globalTag,**options):
327  """
328  _skimming_
329 
330  skimming method overload for the prompt skiming
331 
332  """
333  options = defaultOptions
334  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
335  options.step = "SKIM:"+('+'.join(skims))
336  options.name = "SKIM"
337  options.conditions = gtNameAndConnect(globalTag, args)
338  process = cms.Process("SKIM", self.eras)
339  process.source = cms.Source("PoolSource")
340 
341  if 'customs' in args:
342  options.customisation_file=args['customs']
343 
344  configBuilder = ConfigBuilder(options, process = process)
345  configBuilder.prepare()
346 
347  return process
Reco.Reco.skimming
def skimming
Definition: Reco.py:325
Utils.gtNameAndConnect
def gtNameAndConnect
Definition: Utils.py:137
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21
def Reco.Reco.visualizationProcessing (   self,
  globalTag,
  args 
) 
_visualizationProcessing_

Definition at line 148 of file Reco.py.

References Reco.Reco._checkRepackedFlag(), Impl.pplowpu.pplowpu.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.cosmics.cosmics.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.pp.pp.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Reco.Reco.cbSc, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.cbSc, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Utils.dictIO(), Impl.cosmicsEra_Run2_2016.cosmicsEra_Run2_2016.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.eras, Impl.cosmicsEra_Run2_25ns.cosmicsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_2016_pA.ppEra_Run2_2016_pA.eras, Impl.pplowpuEra_Run2_2016.pplowpuEra_Run2_2016.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_2016_trackingLowPU.ppEra_Run2_2016_trackingLowPU.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), Reco.Reco.visModifiers, Impl.pp.pp.visModifiers, and Impl.HeavyIons.HeavyIons.visModifiers.

148 
149  def visualizationProcessing(self, globalTag, **args):
150  """
151  _visualizationProcessing_
152 
153  """
154 
155  options = Options()
156  options.__dict__.update(defaultOptions.__dict__)
157  options.scenario = self.cbSc
158  # FIXME: do we need L1Reco here?
159  options.step =''
160  if 'preFilter' in args:
161  options.step +='FILTER:'+args['preFilter']+','
162 
163  eiStep=''
164  if self.cbSc == 'pp':
165  eiStep=',EI'
166 
167  options.step += 'RAW2DIGI,L1Reco,RECO'+eiStep+',ENDJOB'
168 
169 
170  dictIO(options,args)
171  options.conditions = gtNameAndConnect(globalTag, args)
172  options.timeoutOutput = True
173  # FIXME: maybe can go...maybe not
174  options.filein = 'tobeoverwritten.xyz'
175 
176  if 'inputSource' in args:
177  options.filetype = args['inputSource']
178  else:
179  # this is the default as this is what is needed on the OnlineCluster
180  options.filetype = 'DQMDAQ'
181 
182  print "Using %s source"%options.filetype
183 
184  process = cms.Process('RECO', cms.ModifierChain(self.eras, self.visModifiers) )
185 
186  if 'customs' in args:
187  options.customisation_file=args['customs']
188 
189  self._checkRepackedFlag(options, **args)
190 
191  cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
192 
193  cb.prepare()
194 
195 
196 
197 
198  # FIXME: not sure abou this one...drop for the moment
199  # addMonitoring(process)
200 
201  return process
202 
203 
204 
Reco.Reco.visModifiers
visModifiers
Definition: Reco.py:24
Utils.gtNameAndConnect
def gtNameAndConnect
Definition: Utils.py:137
Reco.Reco.visualizationProcessing
def visualizationProcessing
Definition: Reco.py:148
Utils.dictIO
def dictIO
Definition: Utils.py:123
Reco.Reco._checkRepackedFlag
def _checkRepackedFlag
Definition: Reco.py:34
Reco.Reco.cbSc
cbSc
Definition: Reco.py:21

Member Data Documentation

Reco.Reco.cbSc

Definition at line 21 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.expressModifiers

Definition at line 23 of file Reco.py.

Referenced by Reco.Reco.expressProcessing().

Reco.Reco.promptModifiers

Definition at line 22 of file Reco.py.

Referenced by Reco.Reco.promptReco().

Reco.Reco.recoSeq

Definition at line 20 of file Reco.py.

Referenced by Reco.Reco.promptReco().

Reco.Reco.visModifiers

Definition at line 24 of file Reco.py.

Referenced by Reco.Reco.visualizationProcessing().

Generated for CMSSW Reference Manual by doxygen 1.8.5