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
 
 recoSeq
 

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=''
self.cbSc=self.__class__.__name__
Reco.Reco.__init__
def __init__
Definition: Reco.py:18
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 31 of file Reco.py.

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

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

Proton collisions data taking AlCa Harvesting

Definition at line 279 of file Reco.py.

References Impl.cosmics.cosmics.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.pp.pp.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.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_25ns.cosmicsEra_Run2_25ns.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.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_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), and join().

279 
280  def alcaHarvesting(self, globalTag, datasetName, **args):
281  """
282  _alcaHarvesting_
283 
284  Proton collisions data taking AlCa Harvesting
285 
286  """
287  skims = []
288  if 'skims' in args:
289  skims = args['skims']
290 
291 
292  if 'alcapromptdataset' in args:
293  skims.append('@'+args['alcapromptdataset'])
294 
295  if len(skims) == 0: return None
296  options = defaultOptions
297  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
298  options.step = "ALCAHARVEST:"+('+'.join(skims))
299  options.name = "ALCAHARVEST"
300  options.conditions = gtNameAndConnect(globalTag, args)
301 
302  process = cms.Process("ALCAHARVEST", self.eras)
303  process.source = cms.Source("PoolSource")
304 
305  if 'customs' in args:
306  options.customisation_file=args['customs']
307 
308  configBuilder = ConfigBuilder(options, process = process)
309  configBuilder.prepare()
310 
311  #
312  # customise process for particular job
313  #
314  process.source.processingMode = cms.untracked.string('RunsAndLumis')
315  process.source.fileNames = cms.untracked(cms.vstring())
316  process.maxEvents.input = -1
317  process.dqmSaver.workflow = datasetName
318 
319  return process
Reco.Reco.alcaHarvesting
def alcaHarvesting
Definition: Reco.py:279
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 200 of file Reco.py.

References Impl.cosmics.cosmics.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.pp.pp.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.ppRun2.ppRun2.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.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_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.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, alcazmumu_cfi.filter, and join().

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

References Impl.cosmics.cosmics.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.pp.pp.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Utils.dqmIOSource(), 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_25ns.hcalnzsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), and Utils.harvestingMode().

253 
254  def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
255  """
256  _dqmHarvesting_
257 
258  Proton collisions data taking DQM Harvesting
259 
260  """
261  options = defaultOptions
262  options.scenario = self.cbSc
263  options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
264  options.name = "EDMtoMEConvert"
265  options.conditions = gtNameAndConnect(globalTag, args)
266 
267  process = cms.Process("HARVESTING", self.eras)
268  process.source = dqmIOSource(args)
269 
270  if 'customs' in args:
271  options.customisation_file=args['customs']
272 
273  configBuilder = ConfigBuilder(options, process = process)
274  configBuilder.prepare()
275 
276  harvestingMode(process,datasetName,args,rANDl=False)
277  return process
278 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:131
Reco.Reco.dqmHarvesting
def dqmHarvesting
Definition: Reco.py:253
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 98 of file Reco.py.

References Reco.Reco._checkRepackedFlag(), Utils.addMonitoring(), Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.cosmics.cosmics.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.pp.pp.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.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.ppEra_Run2_2016.eras, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), and Utils.stepALCAPRODUCER().

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

Proton collision data taking prompt reco

Definition at line 40 of file Reco.py.

References Reco.Reco._checkRepackedFlag(), Utils.addMonitoring(), Impl.cosmics.cosmics.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.pp.pp.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.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_25ns.hcalnzsEra_Run2_25ns.eras, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.eras, Impl.HeavyIonsEra_Run2_HI.HeavyIonsEra_Run2_HI.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, Utils.gtNameAndConnect(), Impl.hcalnzs.hcalnzs.recoSeq, Impl.cosmics.cosmics.recoSeq, Impl.hcalnzsRun2.hcalnzsRun2.recoSeq, Impl.cosmicsRun2.cosmicsRun2.recoSeq, Impl.ppRun2B0T.ppRun2B0T.recoSeq, Impl.ppRun2.ppRun2.recoSeq, Impl.ppRun2at50ns.ppRun2at50ns.recoSeq, Impl.HeavyIons.HeavyIons.recoSeq, Impl.pp.pp.recoSeq, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.recoSeq, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.recoSeq, Impl.HeavyIonsRun2.HeavyIonsRun2.recoSeq, Reco.Reco.recoSeq, Impl.ppEra_Run2_2016.ppEra_Run2_2016.recoSeq, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.recoSeq, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.recoSeq, Utils.stepALCAPRODUCER(), and Utils.stepSKIMPRODUCER().

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

References Impl.cosmics.cosmics.cbSc, Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.pp.pp.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.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_25ns.cosmicsEra_Run2_25ns.eras, Impl.cosmicsEra_Run2_50ns.cosmicsEra_Run2_50ns.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_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Scenario.Scenario.eras, Utils.gtNameAndConnect(), and join().

320 
321  def skimming(self, skims, globalTag,**options):
322  """
323  _skimming_
324 
325  skimming method overload for the prompt skiming
326 
327  """
328  options = defaultOptions
329  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
330  options.step = "SKIM:"+('+'.join(skims))
331  options.name = "SKIM"
332  options.conditions = gtNameAndConnect(globalTag, args)
333  process = cms.Process("SKIM", self.eras)
334  process.source = cms.Source("PoolSource")
335 
336  if 'customs' in args:
337  options.customisation_file=args['customs']
338 
339  configBuilder = ConfigBuilder(options, process = process)
340  configBuilder.prepare()
341 
342  return process
Reco.Reco.skimming
def skimming
Definition: Reco.py:320
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 143 of file Reco.py.

References Reco.Reco._checkRepackedFlag(), Impl.cosmicsRun2.cosmicsRun2.cbSc, Impl.cosmics.cosmics.cbSc, Impl.hcalnzsRun2.hcalnzsRun2.cbSc, Impl.hcalnzs.hcalnzs.cbSc, Impl.ppRun2at50ns.ppRun2at50ns.cbSc, Impl.hcalnzsEra_Run2_2016.hcalnzsEra_Run2_2016.cbSc, Impl.HeavyIonsRun2.HeavyIonsRun2.cbSc, Impl.pp.pp.cbSc, Impl.hcalnzsEra_Run2_25ns.hcalnzsEra_Run2_25ns.cbSc, Impl.ppRun2.ppRun2.cbSc, Impl.HeavyIons.HeavyIons.cbSc, Impl.ppRun2B0T.ppRun2B0T.cbSc, Reco.Reco.cbSc, Impl.ppEra_Run2_2016.ppEra_Run2_2016.cbSc, Impl.ppEra_Run2_25ns.ppEra_Run2_25ns.cbSc, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.cbSc, Utils.dictIO(), 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_25ns.ppEra_Run2_25ns.eras, Impl.ppEra_Run2_2016.ppEra_Run2_2016.eras, Impl.ppEra_Run2_50ns.ppEra_Run2_50ns.eras, Scenario.Scenario.eras, and Utils.gtNameAndConnect().

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

Definition at line 20 of file Reco.py.

Referenced by Reco.Reco.promptReco().

Generated for CMSSW Reference Manual by doxygen 1.8.5