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
MatrixReader.MatrixReader Class Reference
Inheritance diagram for MatrixReader.MatrixReader:

Public Member Functions

def __init__
 
def createWorkFlows
 
def makeCmd
 
def prepare
 
def readMatrix
 
def reset
 
def show
 
def showRaw
 
def showWorkFlows
 
def updateDB
 

Public Attributes

 addCommand
 
 apply
 
 commandLineWf
 
 files
 
 filesPrefMap
 
 nameList
 
 noRun
 
 overWrite
 
 relvalModule
 
 revertDqmio
 maybe we want too level deep input More...
 
 what
 
 wm
 
 workFlows
 
 workFlowSteps
 

Detailed Description

Definition at line 16 of file MatrixReader.py.

Constructor & Destructor Documentation

def MatrixReader.MatrixReader.__init__ (   self,
  opt 
)

Definition at line 18 of file MatrixReader.py.

References PuppiAlgo.reset(), TPedResult.reset(), BinningPointByMap.reset(), ora::NamedReference.reset(), AlcaBeamSpotManager.reset(), ora::IRelationalOperation.reset(), VEcalCalibBlock.reset(), ApvLatencyAnalysis.reset(), ora::Handle< T >.reset(), MatrixReader.MatrixReader.reset(), TB06Tree.reset(), ora::IteratorBuffer.reset(), cond::BaseValueExtractor< T >.reset(), EcalCondHeader.reset(), ora::ContainerIterator.reset(), IMACalibBlock.reset(), ora::OId.reset(), SamplingAnalysis.reset(), CondIter< DataT >.reset(), L3CalibBlock.reset(), FactorizedJetCorrectorCalculator::VariableValues.reset(), DaqScopeModeAnalysis.reset(), ora::MultiRecordInsertOperation.reset(), pos::PixelROCStatus.reset(), FedTimingAnalysis.reset(), TB06TreeH2.reset(), L1MuDTTFMasks.reset(), L1MuDTTFParameters.reset(), L1MuDTPhiLut.reset(), L1MuDTPtaLut.reset(), FedCablingAnalysis.reset(), L1MuDTEtaPatternLut.reset(), L1MuDTQualPatternLut.reset(), PedsOnlyAnalysis.reset(), TB06Reco.reset(), L1MuDTExtLut.reset(), VpspScanAnalysis.reset(), PhysicsTools::Calibration::Histogram< Value_t, Axis_t >.reset(), coral_bridge::AuthenticationCredentialSet.reset(), PhysicsTools::Calibration::Histogram2D< Value_t, AxisX_t, AxisY_t >.reset(), PedestalsAnalysis.reset(), NoiseAnalysis.reset(), OptoScanAnalysis.reset(), ApvTimingAnalysis.reset(), CalibrationAnalysis.reset(), PhysicsTools::Calibration::Histogram3D< Value_t, AxisX_t, AxisY_t, AxisZ_t >.reset(), FastFedCablingAnalysis.reset(), ora::UniqueRef< T >.reset(), PedsFullNoiseAnalysis.reset(), cond::persistency::IOVProxy.reset(), cond::persistency::GTProxy.reset(), CommissioningAnalysis.reset(), ora::InsertOperation.reset(), ora::Ptr< T >.reset(), TB06RecoH2.reset(), ora::BulkInsertOperation.reset(), cond::XMLAuthenticationService::XMLAuthenticationService.reset(), TrackerMap.reset(), ora::UpdateOperation.reset(), ora::DeleteOperation.reset(), DTTFBitArray< N >.reset(), and ora::QueryableVector< Tp >.reset().

18 
19  def __init__(self, opt):
20 
21  self.reset(opt.what)
22 
23  self.wm=opt.wmcontrol
24  self.revertDqmio=opt.revertDqmio
25  self.addCommand=opt.command
26  self.apply=opt.apply
27  self.commandLineWf=opt.workflow
28  self.overWrite=opt.overWrite
29 
30  self.noRun = opt.noRun
31  return
MatrixReader.MatrixReader.revertDqmio
revertDqmio
maybe we want too level deep input
Definition: MatrixReader.py:23

Member Function Documentation

def MatrixReader.MatrixReader.createWorkFlows (   self,
  fileNameIn 
)

Definition at line 406 of file MatrixReader.py.

References MatrixReader.MatrixReader.filesPrefMap, MatrixReader.MatrixReader.nameList, and MatrixReader.MatrixReader.workFlowSteps.

Referenced by MatrixReader.MatrixReader.prepare().

406 
407  def createWorkFlows(self, fileNameIn):
408 
409  prefixIn = self.filesPrefMap[fileNameIn]
410 
411  # get through the list of items and update the requested workflows only
412  keyList = self.workFlowSteps.keys()
413  ids = []
414  for item in keyList:
415  id, pref = item
416  if pref != prefixIn : continue
417  ids.append(id)
418  ids.sort()
419  for key in ids:
420  val = self.workFlowSteps[(key,prefixIn)]
421  num, name, commands, stepList = val
422  nameId = str(num)+'_'+name
423  if nameId in self.nameList:
424  print "==> duplicate name found for ", nameId
425  print ' keeping : ', self.nameList[nameId]
426  print ' ignoring : ', val
427  else:
428  self.nameList[nameId] = val
429 
430  self.workFlows.append(WorkFlow(num, name, commands=commands))
431 
432  return
def MatrixReader.MatrixReader.makeCmd (   self,
  step 
)

Definition at line 74 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.readMatrix().

74 
75  def makeCmd(self, step):
76 
77  cmd = ''
78  cfg = None
79  input = None
80  for k,v in step.items():
81  if 'no_exec' in k : continue # we want to really run it ...
82  if k.lower() == 'cfg':
83  cfg = v
84  continue # do not append to cmd, return separately
85  if k.lower() == 'input':
86  input = v
87  continue # do not append to cmd, return separately
88 
89  #chain the configs
90  #if k.lower() == '--python':
91  # v = 'step%d_%s'%(index,v)
92  cmd += ' ' + k + ' ' + str(v)
93  return cfg, input, cmd
def MatrixReader.MatrixReader.prepare (   self,
  useInput = None,
  refRel = '',
  fromScratch = None 
)

Definition at line 433 of file MatrixReader.py.

References MatrixReader.MatrixReader.createWorkFlows(), MatrixReader.MatrixReader.files, MatrixReader.MatrixReader.readMatrix(), and MatrixReader.MatrixReader.what.

433 
434  def prepare(self, useInput=None, refRel='', fromScratch=None):
435 
436  for matrixFile in self.files:
437  if self.what != 'all' and self.what not in matrixFile:
438  print "ignoring non-requested file",matrixFile
439  continue
440  if self.what == 'all' and ('upgrade' in matrixFile):
441  print "ignoring",matrixFile,"from default matrix"
442  continue
443 
444  try:
445  self.readMatrix(matrixFile, useInput, refRel, fromScratch)
446  except Exception, e:
447  print "ERROR reading file:", matrixFile, str(e)
448  raise
449 
450  try:
451  self.createWorkFlows(matrixFile)
452  except Exception, e:
453  print "ERROR creating workflows :", str(e)
454  raise
455 
def MatrixReader.MatrixReader.readMatrix (   self,
  fileNameIn,
  useInput = None,
  refRel = None,
  fromScratch = None 
)

Definition at line 94 of file MatrixReader.py.

References MatrixReader.MatrixReader.addCommand, MatrixReader.MatrixReader.apply, MatrixReader.MatrixReader.filesPrefMap, join(), MatrixReader.MatrixReader.makeCmd(), python.multivaluedict.map(), MatrixReader.MatrixReader.noRun, MatrixReader.MatrixReader.overWrite, MatrixReader.MatrixReader.relvalModule, MatrixReader.MatrixReader.revertDqmio, MatrixReader.MatrixReader.wm, MatrixReader.MatrixReader.workFlowSteps, and archive.zip.

Referenced by MatrixReader.MatrixReader.prepare(), and MatrixReader.MatrixReader.showRaw().

94 
95  def readMatrix(self, fileNameIn, useInput=None, refRel=None, fromScratch=None):
96 
97  prefix = self.filesPrefMap[fileNameIn]
98 
99  print "processing ", fileNameIn
100 
101  try:
102  _tmpMod = __import__( 'Configuration.PyReleaseValidation.'+fileNameIn )
103  self.relvalModule = sys.modules['Configuration.PyReleaseValidation.'+fileNameIn]
104  except Exception, e:
105  print "ERROR importing file ", fileNameIn, str(e)
106  return
107 
108  print "request for INPUT for ", useInput
109 
110 
111  fromInput={}
112 
113  if useInput:
114  for i in useInput:
115  if ':' in i:
116  (ik,il)=i.split(':')
117  if ik=='all':
118  for k in self.relvalModule.workflows.keys():
119  fromInput[float(k)]=int(il)
120  else:
121  fromInput[float(ik)]=int(il)
122  else:
123  if i=='all':
124  for k in self.relvalModule.workflows.keys():
125  fromInput[float(k)]=0
126  else:
127  fromInput[float(i)]=0
128 
129  if fromScratch:
130  fromScratch=map(float,fromScratch)
131  for num in fromScratch:
132  if num in fromInput:
133  fromInput.pop(num)
134  #overwrite steps
135  if self.overWrite:
136  for p in self.overWrite:
137  self.relvalModule.steps.overwrite(p)
138 
139  #change the origin of dataset on the fly
140  if refRel:
141  if ',' in refRel:
142  refRels=refRel.split(',')
143  if len(refRels)!=len(self.relvalModule.baseDataSetRelease):
144  return
145  self.relvalModule.changeRefRelease(
146  self.relvalModule.steps,
147  zip(self.relvalModule.baseDataSetRelease,refRels)
148  )
149  else:
150  self.relvalModule.changeRefRelease(
151  self.relvalModule.steps,
152  [(x,refRel) for x in self.relvalModule.baseDataSetRelease]
153  )
154 
155 
156  for num, wfInfo in self.relvalModule.workflows.items():
157  commands=[]
158  wfName = wfInfo[0]
159  stepList = wfInfo[1]
160  # if no explicit name given for the workflow, use the name of step1
161  if wfName.strip() == '': wfName = stepList[0]
162  # option to specialize the wf as the third item in the WF list
163  addTo=None
164  addCom=None
165  if len(wfInfo)>=3:
166  addCom=wfInfo[2]
167  if not type(addCom)==list: addCom=[addCom]
168  #print 'added dict',addCom
169  if len(wfInfo)>=4:
170  addTo=wfInfo[3]
171  #pad with 0
172  while len(addTo)!=len(stepList):
173  addTo.append(0)
174 
175  name=wfName
176  stepIndex=0
177  ranStepList=[]
178 
179  #first resolve INPUT possibilities
180  if num in fromInput:
181  ilevel=fromInput[num]
182  #print num,ilevel
183  for (stepIr,step) in enumerate(reversed(stepList)):
184  stepName=step
185  stepI=(len(stepList)-stepIr)-1
186  #print stepIr,step,stepI,ilevel
187  if stepI>ilevel:
188  #print "ignoring"
189  continue
190  if stepI!=0:
191  testName='__'.join(stepList[0:stepI+1])+'INPUT'
192  else:
193  testName=step+'INPUT'
194  #print "JR",stepI,stepIr,testName,stepList
195  if testName in self.relvalModule.steps.keys():
196  #print "JR",stepI,stepIr
197  stepList[stepI]=testName
198  #pop the rest in the list
199  #print "\tmod prepop",stepList
200  for p in range(stepI):
201  stepList.pop(0)
202  #print "\t\tmod",stepList
203  break
204 
205 
206  for (stepI,step) in enumerate(stepList):
207  stepName=step
208  if self.wm:
209  #cannot put a certain number of things in wm
210  if stepName in [
211  #'HARVEST','HARVESTD','HARVESTDreHLT',
212  'RECODFROMRAWRECO','SKIMD','SKIMCOSD','SKIMDreHLT'
213  ]:
214  continue
215 
216  #replace stepName is needed
217  #if stepName in self.replaceStep
218  if len(name) > 0 : name += '+'
219  #any step can be mirrored with INPUT
220  ## maybe we want too level deep input
221  """
222  if num in fromInput:
223  if step+'INPUT' in self.relvalModule.steps.keys():
224  stepName = step+"INPUT"
225  stepList.remove(step)
226  stepList.insert(stepIndex,stepName)
227  """
228  name += stepName
229 
230  if addCom and (not addTo or addTo[stepIndex]==1):
231  from Configuration.PyReleaseValidation.relval_steps import merge
232  copyStep=merge(addCom+[self.relvalModule.steps[stepName]])
233  cfg, input, opts = self.makeCmd(copyStep)
234  else:
235  cfg, input, opts = self.makeCmd(self.relvalModule.steps[stepName])
236 
237  if input and cfg :
238  msg = "FATAL ERROR: found both cfg and input for workflow "+str(num)+' step '+stepName
239  raise MatrixException(msg)
240 
241  if input:
242  cmd = input
243  if self.noRun:
244  cmd.run=[]
245  else:
246  if cfg:
247  cmd = 'cmsDriver.py '+cfg+' '+opts
248  else:
249  cmd = 'cmsDriver.py step'+str(stepIndex+1)+' '+opts
250  if self.wm:
251  cmd+=' --io %s.io --python %s.py'%(stepName,stepName)
252  if self.addCommand:
253  if self.apply:
254  if stepIndex in self.apply or stepName in self.apply:
255  cmd +=' '+self.addCommand
256  else:
257  cmd +=' '+self.addCommand
258  if self.wm and self.revertDqmio=='yes':
259  cmd=cmd.replace('DQMIO','DQM')
260  cmd=cmd.replace('--filetype DQM','')
261  commands.append(cmd)
262  ranStepList.append(stepName)
263  stepIndex+=1
264 
265  self.workFlowSteps[(num,prefix)] = (num, name, commands, ranStepList)
266 
267  return
268 
merge
Definition: merge.py:1
MatrixReader.MatrixReader.revertDqmio
revertDqmio
maybe we want too level deep input
Definition: MatrixReader.py:23
relval_steps
archive.zip
tuple zip
Definition: archive.py:476
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
def MatrixReader.MatrixReader.reset (   self,
  what = 'all' 
)

Definition at line 32 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.__init__(), and MatrixReader.MatrixReader.showRaw().

32 
33  def reset(self, what='all'):
34 
35  self.what = what
36 
37  #a bunch of information, but not yet the WorkFlow object
38  self.workFlowSteps = {}
39  #the actual WorkFlow objects
40  self.workFlows = []
41  self.nameList = {}
42 
43  self.filesPrefMap = {'relval_standard' : 'std-' ,
44  'relval_highstats': 'hi-' ,
45  'relval_pileup': 'PU-' ,
46  'relval_generator': 'gen-',
47  'relval_extendedgen': 'genExt-',
48  'relval_production': 'prod-' ,
49  'relval_ged': 'ged-',
50  'relval_upgrade':'upg-',
51  'relval_identity':'id-',
52  'relval_machine': 'mach-',
53  'relval_unsch': 'unsch-'
54  #, 'relval_premix': 'premix-'
55  }
56 
57  self.files = ['relval_standard' ,
58  'relval_highstats',
59  'relval_pileup',
60  'relval_generator',
61  'relval_extendedgen',
62  'relval_production',
63  'relval_ged',
64  'relval_upgrade',
65  'relval_identity',
66  'relval_machine',
67  'relval_unsch'
68  #, 'relval_premix'
69  ]
70 
71  self.relvalModule = None
72 
73  return
def MatrixReader.MatrixReader.show (   self,
  selected = None,
  extended = True 
)

Definition at line 456 of file MatrixReader.py.

References MatrixReader.MatrixReader.showWorkFlows().

Referenced by Vispa.Main.AboutDialog.AboutDialog.onScreen(), Vispa.Gui.BoxContentDialog.BoxContentDialog.onScreen(), and Vispa.Gui.FindDialog.FindDialog.onScreen().

456 
457  def show(self, selected=None, extended=True):
458 
459  self.showWorkFlows(selected,extended)
460  print '\n','-'*80,'\n'
461 
def MatrixReader.MatrixReader.showRaw (   self,
  useInput,
  refRel = None,
  fromScratch = None,
  what = 'all',
  step1Only = False,
  selected = None 
)

Definition at line 269 of file MatrixReader.py.

References Clusterizer1DCommons.add(), MatrixReader.MatrixReader.files, join(), python.multivaluedict.map(), MatrixReader.MatrixReader.readMatrix(), PuppiAlgo.reset(), BinningPointByMap.reset(), TPedResult.reset(), ora::NamedReference.reset(), AlcaBeamSpotManager.reset(), ora::IRelationalOperation.reset(), ApvLatencyAnalysis.reset(), VEcalCalibBlock.reset(), MatrixReader.MatrixReader.reset(), ora::Handle< T >.reset(), TB06Tree.reset(), ora::IteratorBuffer.reset(), cond::BaseValueExtractor< T >.reset(), EcalCondHeader.reset(), ora::ContainerIterator.reset(), IMACalibBlock.reset(), CondIter< DataT >.reset(), ora::OId.reset(), SamplingAnalysis.reset(), L3CalibBlock.reset(), FactorizedJetCorrectorCalculator::VariableValues.reset(), DaqScopeModeAnalysis.reset(), ora::MultiRecordInsertOperation.reset(), pos::PixelROCStatus.reset(), FedTimingAnalysis.reset(), TB06TreeH2.reset(), L1MuDTTFMasks.reset(), L1MuDTTFParameters.reset(), L1MuDTPhiLut.reset(), L1MuDTPtaLut.reset(), FedCablingAnalysis.reset(), L1MuDTEtaPatternLut.reset(), L1MuDTQualPatternLut.reset(), PedsOnlyAnalysis.reset(), TB06Reco.reset(), VpspScanAnalysis.reset(), L1MuDTExtLut.reset(), PhysicsTools::Calibration::Histogram< Value_t, Axis_t >.reset(), coral_bridge::AuthenticationCredentialSet.reset(), PhysicsTools::Calibration::Histogram2D< Value_t, AxisX_t, AxisY_t >.reset(), NoiseAnalysis.reset(), PedestalsAnalysis.reset(), OptoScanAnalysis.reset(), ApvTimingAnalysis.reset(), CalibrationAnalysis.reset(), PhysicsTools::Calibration::Histogram3D< Value_t, AxisX_t, AxisY_t, AxisZ_t >.reset(), FastFedCablingAnalysis.reset(), ora::UniqueRef< T >.reset(), PedsFullNoiseAnalysis.reset(), cond::persistency::IOVProxy.reset(), cond::persistency::GTProxy.reset(), CommissioningAnalysis.reset(), ora::InsertOperation.reset(), ora::Ptr< T >.reset(), TB06RecoH2.reset(), ora::BulkInsertOperation.reset(), cond::XMLAuthenticationService::XMLAuthenticationService.reset(), TrackerMap.reset(), ora::UpdateOperation.reset(), ora::DeleteOperation.reset(), DTTFBitArray< N >.reset(), ora::QueryableVector< Tp >.reset(), MatrixReader.MatrixReader.revertDqmio, MatrixReader.MatrixReader.what, and MatrixReader.MatrixReader.workFlowSteps.

269 
270  def showRaw(self, useInput, refRel=None, fromScratch=None, what='all',step1Only=False,selected=None):
271 
272  if selected:
273  selected=map(float,selected)
274  for matrixFile in self.files:
275 
276  self.reset(what)
277 
278  if self.what != 'all' and self.what not in matrixFile:
279  print "ignoring non-requested file",matrixFile
280  continue
281 
282  try:
283  self.readMatrix(matrixFile, useInput, refRel, fromScratch)
284  except Exception, e:
285  print "ERROR reading file:", matrixFile, str(e)
286  raise
287 
288  if not self.workFlowSteps: continue
289 
290  dataFileName = matrixFile.replace('relval_', 'cmsDriver_')+'_hlt.txt'
291  outFile = open(dataFileName,'w')
292 
293  print "found ", len(self.workFlowSteps.keys()), ' workflows for ', dataFileName
294  ids = self.workFlowSteps.keys()
295  ids.sort()
296  indexAndSteps=[]
297 
298  writtenWF=0
299  for key in ids:
300  if selected and not (key[0] in selected):
301  continue
302  #trick to skip the HImix IB test
303  if key[0]==203.1 or key[0]==204.1 or key[0]==205.1 or key[0]==4.51 or key[0]==4.52: continue
304  num, name, commands, stepList = self.workFlowSteps[key]
305 
306  wfName,stepNames= name.split('+',1)
307 
308  stepNames=stepNames.replace('+RECODFROMRAWRECO','')
309  stepNames=stepNames.replace('+SKIMCOSD','')
310  stepNames=stepNames.replace('+SKIMD','')
311  if 'HARVEST' in stepNames:
312  #find out automatically what to remove
313  exactb=stepNames.index('+HARVEST')
314  exacte=stepNames.index('+',exactb+1) if ('+' in stepNames[exactb+1:]) else (len(stepNames))
315  stepNames=stepNames.replace(stepNames[exactb:exacte],'')
316  otherSteps = None
317  if '+' in stepNames:
318  step1,otherSteps = stepNames.split('+',1)
319 
320  line = str(num) + ' ++ '+ wfName
321  if otherSteps and not step1Only:
322  line += ' ++ ' +otherSteps.replace('+',',')
323  else:
324  line += ' ++ none'
325  inputInfo=None
326  if not isinstance(commands[0],str):
327  inputInfo=commands[0]
328  if otherSteps:
329  for (i,c) in enumerate(otherSteps.split('+')):
330  #pad with set
331  for p in range(len(indexAndSteps),i+2):
332  indexAndSteps.append(set())
333  indexAndSteps[i+1].add((c,commands[i+1]))
334 
335  if inputInfo :
336  #skip the samples from INPUT when step1Only is on
337  if step1Only: continue
338  line += ' ++ REALDATA: '+inputInfo.dataSet
339  if inputInfo.run!=[]: line += ', RUN:'+'|'.join(map(str,inputInfo.run))
340  line += ', FILES: ' +str(inputInfo.files)
341  line += ', EVENTS: '+str(inputInfo.events)
342  if inputInfo.label!='':
343  line += ', LABEL: ' +inputInfo.label
344  line += ', LOCATION:'+inputInfo.location
345  line += ' @@@'
346  else:
347  line += ' @@@ '+commands[0]
348  if self.revertDqmio=='yes':
349  line=line.replace('DQMIO','DQM')
350  writtenWF+=1
351  outFile.write(line+'\n')
352 
353 
354  outFile.write('\n'+'\n')
355  if step1Only: continue
356 
357  for (index,s) in enumerate(indexAndSteps):
358  for (stepName,cmd) in s:
359  stepIndex=index+1
360  if 'dasquery.log' in cmd: continue
361  line = 'STEP%d ++ '%(stepIndex,) +stepName + ' @@@ '+cmd
362  if self.revertDqmio=='yes':
363  line=line.replace('DQMIO','DQM')
364  outFile.write(line+'\n')
365  outFile.write('\n'+'\n')
366  outFile.close()
367  print "wrote ",writtenWF, ' workflow'+('s' if (writtenWF!=1) else ''),' to ', outFile.name
368  return
369 
MatrixReader.MatrixReader.revertDqmio
revertDqmio
maybe we want too level deep input
Definition: MatrixReader.py:23
Clusterizer1DCommons::add
void add(const std::vector< const T * > &source, std::vector< const T * > &dest)
Definition: Clusterizer1DCommons.h:26
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
def MatrixReader.MatrixReader.showWorkFlows (   self,
  selected = None,
  extended = True 
)

Definition at line 370 of file MatrixReader.py.

References python.multivaluedict.map(), and MatrixReader.MatrixReader.workFlows.

Referenced by MatrixReader.MatrixReader.show().

370 
371  def showWorkFlows(self, selected=None, extended=True):
372  if selected: selected = map(float,selected)
373  maxLen = 100 # for summary, limit width of output
374  fmt1 = "%-6s %-35s [1]: %s ..."
375  fmt2 = " %35s [%d]: %s ..."
376  print "\nfound a total of ", len(self.workFlows), ' workflows:'
377  if selected:
378  print " of which the following", len(selected), 'were selected:'
379  #-ap for now:
380  maxLen = -1 # for individual listing, no limit on width
381  fmt1 = "%-6s %-35s [1]: %s "
382  fmt2 = " %35s [%d]: %s"
383 
384  N=[]
385  for wf in self.workFlows:
386  if selected and float(wf.numId) not in selected: continue
387  if extended: print ''
388  #pad with zeros
389  for i in range(len(N),len(wf.cmds)): N.append(0)
390  N[len(wf.cmds)-1]+=1
391  wfName, stepNames = wf.nameId.split('+',1)
392  for i,s in enumerate(wf.cmds):
393  if extended:
394  if i==0:
395  print fmt1 % (wf.numId, stepNames, (str(s)+' ')[:maxLen])
396  else:
397  print fmt2 % ( ' ', i+1, (str(s)+' ')[:maxLen])
398  else:
399  print "%-6s %-35s "% (wf.numId, stepNames)
400  break
401  print ''
402  for i,n in enumerate(N):
403  if n: print n,'workflows with',i+1,'steps'
404 
405  return
def MatrixReader.MatrixReader.updateDB (   self)

Definition at line 462 of file MatrixReader.py.

References MatrixReader.MatrixReader.workFlows.

462 
463  def updateDB(self):
464 
465  import pickle
466  pickle.dump(self.workFlows, open('theMatrix.pkl', 'w') )
467 
468  return
469 

Member Data Documentation

MatrixReader.MatrixReader.addCommand

Definition at line 24 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.readMatrix().

MatrixReader.MatrixReader.apply

Definition at line 25 of file MatrixReader.py.

Referenced by heavyIonTools.ConfigureHeavyIons.__call__(), editorTools.UserCodeTool.__call__(), HiCoreTools.RestrictInputToAOD.__call__(), coreTools.RunOnData.__call__(), trackTools.MakeAODTrackCandidates.__call__(), runJetUncertainties.RunJetUncertainties.__call__(), metTools.AddMETCollection.__call__(), heavyIonTools.ProductionDefaults.__call__(), editorTools.ChangeSource.__call__(), HiCoreTools.RemoveMCMatching.__call__(), cmsswVersionTools.PickRelValInputFiles.__call__(), coreTools.RemoveMCMatching.__call__(), trackTools.MakePATTrackCandidates.__call__(), trigTools.SwitchOnTrigger.__call__(), jetTools.AddJetCollection.__call__(), heavyIonTools.SelectionDefaults.__call__(), HiCoreTools.RemoveAllPATObjectsBut.__call__(), heavyIonTools.DisbaleMonteCarloDeps.__call__(), runType1CaloMEtUncertainties.RunType1CaloMEtUncertainties.__call__(), HiCoreTools.RemoveSpecificPATObjects.__call__(), trigTools.SwitchOnTriggerStandAlone.__call__(), trackTools.MakeTrackCandidates.__call__(), runMVAMEtUncertainties.RunMVAMEtUncertainties.__call__(), tauTools.AddTauCollection.__call__(), trigTools.SwitchOnTriggerMatching.__call__(), HiCoreTools.RemoveCleaning.__call__(), runType1PFMEtUncertainties.RunType1PFMEtUncertainties.__call__(), HiCoreTools.AddCleaning.__call__(), runNoPileUpMEtUncertainties.RunNoPileUpMEtUncertainties.__call__(), trigTools.SwitchOnTriggerMatchingStandAlone.__call__(), trigTools.SwitchOnTriggerMatchEmbedding.__call__(), jetTools.SwitchJetCollection.__call__(), jetTools.AddJetID.__call__(), jetTools.SetTagInfos.__call__(), and MatrixReader.MatrixReader.readMatrix().

MatrixReader.MatrixReader.commandLineWf

Definition at line 26 of file MatrixReader.py.

MatrixReader.MatrixReader.files

Definition at line 56 of file MatrixReader.py.

Referenced by chain.Chain._guessTreeName(), MatrixReader.MatrixReader.prepare(), and MatrixReader.MatrixReader.showRaw().

MatrixReader.MatrixReader.filesPrefMap

Definition at line 42 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.createWorkFlows(), and MatrixReader.MatrixReader.readMatrix().

MatrixReader.MatrixReader.nameList

Definition at line 40 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.createWorkFlows().

MatrixReader.MatrixReader.noRun

Definition at line 29 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.readMatrix().

MatrixReader.MatrixReader.overWrite

Definition at line 27 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.readMatrix().

MatrixReader.MatrixReader.relvalModule

Definition at line 70 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.readMatrix().

MatrixReader.MatrixReader.revertDqmio

maybe we want too level deep input

Definition at line 23 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.readMatrix(), and MatrixReader.MatrixReader.showRaw().

MatrixReader.MatrixReader.what

Definition at line 34 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.prepare(), and MatrixReader.MatrixReader.showRaw().

MatrixReader.MatrixReader.wm

Definition at line 22 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.readMatrix().

MatrixReader.MatrixReader.workFlows

Definition at line 39 of file MatrixReader.py.

Referenced by MatrixRunner.MatrixRunner.runTests(), MatrixReader.MatrixReader.showWorkFlows(), and MatrixReader.MatrixReader.updateDB().

MatrixReader.MatrixReader.workFlowSteps

Definition at line 37 of file MatrixReader.py.

Referenced by MatrixReader.MatrixReader.createWorkFlows(), MatrixReader.MatrixReader.readMatrix(), and MatrixReader.MatrixReader.showRaw().

Generated for CMSSW Reference Manual by doxygen 1.8.5