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

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

163 
164  def alcaHarvesting(self, globalTag, datasetName, **args):
165  """
166  _alcaHarvesting_
167 
168  Proton collisions data taking AlCa Harvesting
169 
170  """
171  if not 'skims' in args: return None
172  options = defaultOptions
173  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
174  options.step = "ALCAHARVEST:"+('+'.join(args['skims']))
175  options.name = "ALCAHARVEST"
176  options.conditions = globalTag
177 
178  process = cms.Process("ALCAHARVEST")
179  process.source = cms.Source("PoolSource")
180  configBuilder = ConfigBuilder(options, process = process)
181  configBuilder.prepare()
182 
183  #
184  # customise process for particular job
185  #
186  process.source.processingMode = cms.untracked.string('RunsAndLumis')
187  process.source.fileNames = cms.untracked(cms.vstring())
188  process.maxEvents.input = -1
189  process.dqmSaver.workflow = datasetName
190 
191  return process
Reco.Reco.alcaHarvesting
def alcaHarvesting
Definition: Reco.py:163
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 93 of file Reco.py.

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

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

141 
142  def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
143  """
144  _dqmHarvesting_
145 
146  Proton collisions data taking DQM Harvesting
147 
148  """
149  options = defaultOptions
150  options.scenario = self.cbSc
151  options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
152  options.name = "EDMtoMEConvert"
153  options.conditions = globalTag
154 
155  process = cms.Process("HARVESTING")
156  process.source = dqmIOSource(args)
157  configBuilder = ConfigBuilder(options, process = process)
158  configBuilder.prepare()
159 
160  harvestingMode(process,datasetName,args,rANDl=False)
161  return process
162 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:116
Reco.Reco.dqmHarvesting
def dqmHarvesting
Definition: Reco.py:141
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 192 of file Reco.py.

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

192 
193  def skimming(self, skims, globalTag,**options):
194  """
195  _skimming_
196 
197  skimming method overload for the prompt skiming
198 
199  """
200  options = defaultOptions
201  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
202  options.step = "SKIM:"+('+'.join(skims))
203  options.name = "SKIM"
204  options.conditions = globalTag
205  process = cms.Process("SKIM")
206  process.source = cms.Source("PoolSource")
207  configBuilder = ConfigBuilder(options, process = process)
208  configBuilder.prepare()
209 
210  return process
Reco.Reco.skimming
def skimming
Definition: Reco.py:192
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