Public Member Functions
def	__init__
def	initProcess
def	run
def	writeCfg
Public Attributes
	config
	configFiles
	dir
	dqm_files
	process
	pset_name
	pset_template
	result_dir
	runnumber
	task

Detailed Description

Definition at line 6 of file DTDQMHarvesting.py.

Constructor & Destructor Documentation

def DTDQMHarvesting::DTDQMHarvesting::__init__	(	self,
		run,
		dir,
		dqm_files,
		result_dir,
		config = `None`
	)

Definition at line 7 of file DTDQMHarvesting.py.

00008                                                                     :
00009         self.runnumber = int(run)
00010         self.dir = dir
00011         self.result_dir = result_dir
00012         self.config = config
00013         self.dqm_files = dqm_files
00014 
00015         self.pset_name = 'dtDQMClient_cfg.py'
00016         self.pset_template = 'CalibMuon.DTCalibration.dtDQMClientAlca_cfg'
00017 
00018         self.process = None
00019         self.initProcess()
00020         self.configFiles = []
00021         self.configFiles.append(self.pset_name)
00022         self.task = CmsswTask(self.dir,self.configFiles)

Member Function Documentation

def DTDQMHarvesting::DTDQMHarvesting::initProcess ( self )

Definition at line 23 of file DTDQMHarvesting.py.

00024                          :
00025         self.process = loadCmsProcess(self.pset_template)
00026         self.process.GlobalTag.globaltag = self.config.globaltag
00027 
00028         if hasattr(self.config,'inputTTrigDB') and self.config.inputTTrigDB:
00029             label = ''
00030             if hasattr(self.config,'runOnCosmics') and self.config.runOnCosmics: label = 'cosmics'
00031             addPoolDBESSource(process = self.process,
00032                               moduleName = 'tTrigDB',record = 'DTTtrigRcd',tag = 'ttrig',label = label,
00033                               connect = 'sqlite_file:%s' % os.path.abspath(self.config.inputTTrigDB))
00034 
00035         if hasattr(self.config,'inputVDriftDB') and self.config.inputVDriftDB:
00036             addPoolDBESSource(process = self.process,
00037                               moduleName = 'vDriftDB',record = 'DTMtimeRcd',tag = 'vDrift',
00038                               connect = 'sqlite_file:%s' % os.path.abspath(self.config.inputVDriftDB))
00039 
00040         if hasattr(self.config,'inputDBTag') and self.config.inputDBTag:
00041             tag = self.config.inputDBTag
00042             record = self.config.inputDBRcd
00043             connect = self.config.connectStrDBTag
00044             moduleName = 'customDB%s' % record 
00045             addPoolDBESSource(process = self.process,
00046                               moduleName = moduleName,record = record,tag = tag,
00047                               connect = connect)
00048 
00049         self.process.source.fileNames = self.dqm_files
00050         self.process.dqmSaver.dirName = os.path.abspath(self.result_dir)
00051         if self.config:
00052             label = 'dtDQMValidation'
00053             if hasattr(self.config,'label') and self.config.label: label = self.config.label 
00054             workflowName = dqmWorkflowName(self.config.datasetpath,label,self.config.trial)
00055             self.process.dqmSaver.workflow = workflowName
00056         if self.process.DQMStore.collateHistograms == True: self.process.dqmSaver.forceRunNumber = self.runnumber

def DTDQMHarvesting::DTDQMHarvesting::run ( self )

Definition at line 61 of file DTDQMHarvesting.py.

00062                  :
00063         self.task.run()
00064         return

def DTDQMHarvesting::DTDQMHarvesting::writeCfg ( self )

Definition at line 57 of file DTDQMHarvesting.py.

00058                       :
00059         writeCfg(self.process,self.dir,self.pset_name)   
00060         #writeCfgPkl(self.process,self.dir,self.pset_name)