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
 

Public Attributes

 cbSc
 
 recoSeq
 

Detailed Description

Definition at line 21 of file Reco.py.

Constructor & Destructor Documentation

def Reco.Reco.__init__ (   self)

Definition at line 22 of file Reco.py.

22 
23  def __init__(self):
24  self.recoSeq=''
self.cbSc=self.__class__.__name__
def __init__
Definition: Reco.py:22
recoSeq
Definition: Reco.py:23
cbSc
Definition: Reco.py:24

Member Function Documentation

def Reco.Reco.alcaHarvesting (   self,
  globalTag,
  datasetName,
  args 
)
_alcaHarvesting_

Proton collisions data taking AlCa Harvesting

Definition at line 157 of file Reco.py.

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

158  def alcaHarvesting(self, globalTag, datasetName, **args):
159  """
160  _alcaHarvesting_
161 
162  Proton collisions data taking AlCa Harvesting
163 
164  """
165  if not 'skims' in args: return None
166  options = defaultOptions
167  options.scenario = self.cbSc if hasattr(self,'cbSc') else self.__class__.__name__
168  options.step = "ALCAHARVEST:"+('+'.join(args['skims']))
169  options.name = "ALCAHARVEST"
170  options.conditions = globalTag
171 
172  process = cms.Process("ALCAHARVEST")
173  process.source = cms.Source("PoolSource")
174  configBuilder = ConfigBuilder(options, process = process)
175  configBuilder.prepare()
176 
177  #
178  # customise process for particular job
179  #
180  process.source.processingMode = cms.untracked.string('RunsAndLumis')
181  process.source.fileNames = cms.untracked(cms.vstring())
182  process.maxEvents.input = -1
183  process.dqmSaver.workflow = datasetName
184 
185  return process
def alcaHarvesting
Definition: Reco.py:157
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
cbSc
Definition: Reco.py:24
def Reco.Reco.alcaSkim (   self,
  skims,
  args 
)
_alcaSkim_

AlcaReco processing & skims for proton collisions

Definition at line 91 of file Reco.py.

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

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

Proton collisions data taking DQM Harvesting

Definition at line 135 of file Reco.py.

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

136  def dqmHarvesting(self, datasetName, runNumber, globalTag, **args):
137  """
138  _dqmHarvesting_
139 
140  Proton collisions data taking DQM Harvesting
141 
142  """
143  options = defaultOptions
144  options.scenario = self.cbSc
145  options.step = "HARVESTING"+dqmSeq(args,':dqmHarvesting')
146  options.name = "EDMtoMEConvert"
147  options.conditions = globalTag
148 
149  process = cms.Process("HARVESTING")
150  process.source = dqmIOSource(args)
151  configBuilder = ConfigBuilder(options, process = process)
152  configBuilder.prepare()
153 
154  harvestingMode(process,datasetName,args,rANDl=True)
155  return process
156 
def dqmSeq
Definition: Utils.py:116
def dqmHarvesting
Definition: Reco.py:135
def dqmIOSource
Definition: Utils.py:88
def harvestingMode
Definition: Utils.py:99
cbSc
Definition: Reco.py:24
def Reco.Reco.expressProcessing (   self,
  globalTag,
  args 
)
_expressProcessing_

Proton collision data taking express processing

Definition at line 63 of file Reco.py.

References Utils.addMonitoring(), Impl.hcalnzs.hcalnzs.cbSc, Reco.Reco.cbSc, Utils.dictIO(), Utils.dqmSeq(), and Utils.stepALCAPRODUCER().

63 
64  def expressProcessing(self, globalTag, **args):
65  """
66  _expressProcessing_
67 
68  Proton collision data taking express processing
69 
70  """
71  step = stepALCAPRODUCER(args['skims'])
72  dqmStep= dqmSeq(args,'')
73  options = Options()
74  options.__dict__.update(defaultOptions.__dict__)
75  options.scenario = self.cbSc
76  options.step = 'RAW2DIGI,L1Reco,RECO'+step+',DQM'+dqmStep+',ENDJOB'
77  dictIO(options,args)
78  options.conditions = globalTag
79  options.filein = 'tobeoverwritten.xyz'
80  if 'inputSource' in args:
81  options.filetype = args['inputSource']
82  process = cms.Process('RECO')
83  cb = ConfigBuilder(options, process = process, with_output = True, with_input = True)
84 
85  cb.prepare()
86 
87  addMonitoring(process)
88 
89  return process
90 
def dqmSeq
Definition: Utils.py:116
def stepALCAPRODUCER
Definition: Utils.py:9
def addMonitoring
Definition: Utils.py:23
def dictIO
Definition: Utils.py:108
cbSc
Definition: Reco.py:24
def expressProcessing
Definition: Reco.py:63
def Reco.Reco.promptReco (   self,
  globalTag,
  args 
)
_promptReco_

Proton collision data taking prompt reco

Definition at line 33 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().

33 
34  def promptReco(self, globalTag, **args):
35  """
36  _promptReco_
37 
38  Proton collision data taking prompt reco
39 
40  """
41  step = stepALCAPRODUCER(args['skims'])
42  dqmStep= dqmSeq(args,'')
43  options = Options()
44  options.__dict__.update(defaultOptions.__dict__)
45  options.scenario = self.cbSc
46  options.step = 'RAW2DIGI,L1Reco,RECO'+self.recoSeq+step+',DQM'+dqmStep+',ENDJOB'
47  dictIO(options,args)
48  options.conditions = globalTag
49 
50  process = cms.Process('RECO')
51  cb = ConfigBuilder(options, process = process, with_output = True)
52 
53  # Input source
54  process.source = cms.Source("PoolSource",
55  fileNames = cms.untracked.vstring()
56  )
57  cb.prepare()
58 
59  addMonitoring(process)
60 
61  return process
62 
def dqmSeq
Definition: Utils.py:116
def stepALCAPRODUCER
Definition: Utils.py:9
def addMonitoring
Definition: Utils.py:23
def promptReco
Definition: Reco.py:33
def dictIO
Definition: Utils.py:108
recoSeq
Definition: Reco.py:23
cbSc
Definition: Reco.py:24

Member Data Documentation

Reco.Reco.cbSc

Definition at line 24 of file Reco.py.

Referenced by Reco.Reco.alcaHarvesting(), Reco.Reco.alcaSkim(), Impl.DataScouting.DataScouting.dqmHarvesting(), Reco.Reco.dqmHarvesting(), Reco.Reco.expressProcessing(), Impl.DataScouting.DataScouting.promptReco(), and Reco.Reco.promptReco().

Reco.Reco.recoSeq

Definition at line 23 of file Reco.py.

Referenced by Reco.Reco.promptReco().