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

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

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

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

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

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

131 
132  def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
133  """
134  _dqmHarvesting_
135 
136  Proton collisions data taking DQM Harvesting
137 
138  """
139  options = defaultOptions
140  options.scenario = self.cbSc
141  options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
142  options.name = "EDMtoMEConvert"
143  options.conditions = globalTag
144 
145  process = cms.Process("HARVESTING")
146  process.source = dqmIOSource(args)
147  configBuilder = ConfigBuilder(options, process = process)
148  configBuilder.prepare()
149 
150  harvestingMode(process,datasetName,args,rANDl=False)
151  return process
152 
Utils.dqmSeq
def dqmSeq
Definition: Utils.py:116
Reco.Reco.dqmHarvesting
def dqmHarvesting
Definition: Reco.py:131
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  options.filein = 'tobeoverwritten.xyz'
76  if 'inputSource' in args:
77  options.fileType = args['inputSource']
78  process = cms.Process('RECO')
79  cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
80 
81  cb.prepare()
82 
83  addMonitoring(process)
84 
85  return process
86 
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 182 of file Reco.py.

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

182 
183  def skimming(self, skims, globalTag,**options):
184  """
185  _skimming_
186 
187  skimming method overload for the prompt skiming
188 
189  """
190  options = defaultOptions
191  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
192  options.step = "SKIM:"+('+'.join(skims))
193  options.name = "SKIM"
194  options.conditions = globalTag
195  process = cms.Process("SKIM")
196  process.source = cms.Source("PoolSource")
197  configBuilder = ConfigBuilder(options, process = process)
198  configBuilder.prepare()
199 
200  return process
Reco.Reco.skimming
def skimming
Definition: Reco.py:182
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