Public Member Functions
def	__init__ (self, what='standard', strict=True)

def	getConfig (self, wfNumber, step)

def	getKey (self, wfNumber, step)

def	getProcess (self, wfNumber, step)

def	identityTest (self, wfNumber, step)

def	listAll (self)

def	load (self, wfNumber, step)

Public Attributes
	configBuilders

	mrd

	processes

	strict

Detailed Description

Definition at line 5 of file MatrixToProcess.py.

Constructor & Destructor Documentation

◆ init()

def MatrixToProcess.MatrixToProcess.__init__	(	self,
		what = `'standard'`,
		strict = `True`
	)

Definition at line 7 of file MatrixToProcess.py.

     def __init__(self,what='standard',strict=True):
         from Configuration.PyReleaseValidation.MatrixReader import MatrixReader
         self.mrd = MatrixReader(what,noRun=True)
         self.mrd.prepare('all','',None)
         self.configBuilders={}
         self.processes={}
         self.strict=strict

Member Function Documentation

◆ getConfig()

def MatrixToProcess.MatrixToProcess.getConfig	(	self,
		wfNumber,
		step
	)

Definition at line 52 of file MatrixToProcess.py.

     def getConfig(self,wfNumber,step):
         key=self.getKey(wfNumber,step)
         if not key in self.configBuilders:   self.getProcess(wfNumber,step)
         if not key in self.configBuilders: return None
         return self.configBuilders[key].pythonCfgCode
  

References MatrixToProcess.MatrixToProcess.configBuilders, MatrixToProcess.MatrixToProcess.getKey(), TmModule.getKey(), DTCalibrationMap.getKey(), L1TUtmCut.getKey(), and MatrixToProcess.MatrixToProcess.getProcess().

◆ getKey()

def MatrixToProcess.MatrixToProcess.getKey	(	self,
		wfNumber,
		step
	)

Definition at line 14 of file MatrixToProcess.py.

     def getKey(self,wfNumber,step):
         return str(wfNumber)+':'+str(step)
     

References str.

Referenced by MatrixToProcess.MatrixToProcess.getConfig(), MatrixToProcess.MatrixToProcess.getProcess(), MatrixToProcess.MatrixToProcess.identityTest(), and MatrixToProcess.MatrixToProcess.load().

◆ getProcess()

def MatrixToProcess.MatrixToProcess.getProcess	(	self,
		wfNumber,
		step
	)

Definition at line 17 of file MatrixToProcess.py.

     def getProcess(self,wfNumber,step):
         key=self.getKey(wfNumber,step)
         if not key in self.configBuilders:
             self.load(wfNumber,step)
         if not key in self.configBuilders:
             return None
         return self.configBuilders[key].process
  

References MatrixToProcess.MatrixToProcess.configBuilders, MatrixToProcess.MatrixToProcess.getKey(), TmModule.getKey(), DTCalibrationMap.getKey(), L1TUtmCut.getKey(), VisualizationOptions.load(), BTagCalibrationReader::BTagCalibrationReaderImpl.load(), MatrixToProcess.MatrixToProcess.load(), BTagCalibrationReader.load(), cond::persistency::GTEditor.load(), L1MuDTPtaLut.load(), L1MuDTPhiLut.load(), cond::persistency::IOVEditor.load(), L1MuDTEtaPatternLut.load(), L1MuDTQualPatternLut.load(), PiecewiseScalingPolynomial.load(), L1MuDTExtLut.load(), HBHENegativeEFilter.load(), HBHEChannelGroups.load(), cond::persistency::RunInfoProxy.load(), HcalIndexLookup.load(), cond::persistency::GTProxy.load(), cond::persistency::IOVProxy.load(), OOTPileupCorrData.load(), TrackerMap.load(), ConfigBuilder.ConfigBuilder.load(), and tkal_create_file_lists._DasCache.load().

Referenced by MatrixToProcess.MatrixToProcess.getConfig(), MatrixToProcess.MatrixToProcess.identityTest(), and MatrixToProcess.MatrixToProcess.listAll().

◆ identityTest()

def MatrixToProcess.MatrixToProcess.identityTest	(	self,
		wfNumber,
		step
	)

Definition at line 58 of file MatrixToProcess.py.

     def identityTest(self,wfNumber,step):
         self.getProcess(wfNumber,step)
         key=self.getKey(wfNumber,step)
         if not key in self.configBuilders: return None
  
         cb=self.configBuilders[key]
         #need to compare those two for identity
         cb.process
         cd.pythonCfgCode
  
                     

References MatrixToProcess.MatrixToProcess.configBuilders, MatrixToProcess.MatrixToProcess.getKey(), TmModule.getKey(), DTCalibrationMap.getKey(), L1TUtmCut.getKey(), and MatrixToProcess.MatrixToProcess.getProcess().

◆ listAll()

def MatrixToProcess.MatrixToProcess.listAll ( self )

Definition at line 69 of file MatrixToProcess.py.

     def listAll(self):
         for wf in self.mrd.workFlows:
             step=1
             print('---------------------') 
             print('process workflow',wf.numId)
             print()
             while self.load(float(wf.numId),step):
                 p=self.getProcess(float(wf.numId),step)
                 print(', '.join(s.label() for s in p.schedule))
                 #print p.outputModules()
                 step+=1
  

References dqmMemoryStats.float, MatrixToProcess.MatrixToProcess.getProcess(), join(), VisualizationOptions.load(), BTagCalibrationReader::BTagCalibrationReaderImpl.load(), MatrixToProcess.MatrixToProcess.load(), BTagCalibrationReader.load(), cond::persistency::GTEditor.load(), L1MuDTPtaLut.load(), L1MuDTPhiLut.load(), cond::persistency::IOVEditor.load(), L1MuDTEtaPatternLut.load(), L1MuDTQualPatternLut.load(), PiecewiseScalingPolynomial.load(), L1MuDTExtLut.load(), HBHENegativeEFilter.load(), HBHEChannelGroups.load(), cond::persistency::RunInfoProxy.load(), HcalIndexLookup.load(), cond::persistency::GTProxy.load(), cond::persistency::IOVProxy.load(), OOTPileupCorrData.load(), TrackerMap.load(), ConfigBuilder.ConfigBuilder.load(), tkal_create_file_lists._DasCache.load(), MatrixToProcess.MatrixToProcess.mrd, and print().

◆ load()

def MatrixToProcess.MatrixToProcess.load	(	self,
		wfNumber,
		step
	)

Definition at line 25 of file MatrixToProcess.py.

     def load(self,wfNumber,step):
         from Configuration.Applications.ConfigBuilder import ConfigBuilder
         from Configuration.Applications.cmsDriverOptions import OptionsFromCommand
         import copy
  
         if len(self.configBuilders)!=0 and self.strict:
             raise Exception('one should never be loading more than one process at a time due to python loading/altering feature')
         key=self.getKey(wfNumber,step)
         if key in self.configBuilders:
             return True
         
         for wf in self.mrd.workFlows:
             if float(wf.numId)!=wfNumber: continue
  
             if not hasattr(wf,'cmdStep%d'%(step)): continue
             if not getattr(wf,'cmdStep%d'%(step)): continue
             
             command=getattr(wf,'cmdStep%d'%(step))
             opt=OptionsFromCommand(command)
             if opt:
                 cb = ConfigBuilder(opt,with_input=True,with_output=True)
                 cb.prepare()
                 self.configBuilders[key]=copy.copy(cb)
                 return True
         print("could not satisfy the request for step",step,"of workflow",wfNumber)
         return False
                              