Utils Namespace Reference

Classes
class	LoadPrerequisiteSource
Functions
def	addMonitoring
def	dictIO
def	dqmIOSource
def	dqmSeq
def	harvestingMode
def	stepALCAPRODUCER
def	validateProcess

---

Function Documentation

def Utils::addMonitoring

(

process

)

_addMonitoring_

Add the monitoring services to the process provided
in order to write out performance summaries to the framework job report

Definition at line 23 of file Utils.py.

                          :
    """
    _addMonitoring_
    
    Add the monitoring services to the process provided
    in order to write out performance summaries to the framework job report
    """
    import FWCore.ParameterSet.Config as cms
    
    process.SimpleMemoryCheck = cms.Service("SimpleMemoryCheck",
                                            jobReportOutputOnly = cms.untracked.bool(True)
                                            )
    process.Timing = cms.Service("Timing",
                                 summaryOnly = cms.untracked.bool(True)
                                 )
    
    return process

def Utils::dictIO	(		options,
			args
	)

Definition at line 108 of file Utils.py.

                        :
    if args.has_key('outputs'):
        options.outputDefinition = args['outputs'].__str__()
    else:
        writeTiers = args.get('writeTiers', [])
        options.eventcontent = ','.join(writeTiers)
        options.datatier = ','.join(writeTiers)

def Utils::dqmIOSource

(

args

)

Definition at line 88 of file Utils.py.

                     :
    import FWCore.ParameterSet.Config as cms
    if args.get('newDQMIO', False):
        return cms.Source("DQMRootSource",
                          fileNames = cms.untracked(cms.vstring())
                          )
    else:
        return cms.Source("PoolSource",
                          fileNames = cms.untracked(cms.vstring())
                          )

def Utils::dqmSeq	(		args,
			default
	)

Definition at line 116 of file Utils.py.

                        :
    if 'dqmSeq' in args and len(args['dqmSeq'])!=0:
        return ':'+('+'.join(args['dqmSeq']))
    else:
        return default
            

def Utils::harvestingMode	(		process,
			datasetName,
			args,
			rANDl = True
	)

Definition at line 99 of file Utils.py.

                                                         :
    import FWCore.ParameterSet.Config as cms
    if rANDl and (not args.get('newDQMIO', False)):
        process.source.processingMode = cms.untracked.string('RunsAndLumis')
    process.dqmSaver.workflow = datasetName
    process.dqmSaver.saveByLumiSection = 1
    if args.has_key('referenceFile') and args.get('referenceFile', ''):
        process.DQMStore.referenceFileName = cms.untracked.string(args['referenceFile'])

def Utils::stepALCAPRODUCER

(

skims

)

_stepALCAPRODUCER_

Creates and returns the configuration string for the ALCAPRODUCER step
starting from the list of AlcaReco path to be run.

Definition at line 9 of file Utils.py.

                           :
    """
    _stepALCAPRODUCER_

    Creates and returns the configuration string for the ALCAPRODUCER step
    starting from the list of AlcaReco path to be run.

    """

    step = ''
    if len(skims) >0:
        step = ',ALCAPRODUCER:'+('+'.join(skims))
    return step

def Utils::validateProcess

(

process

)

_validateProcess_

Check attributes of process are appropriate for production
This method returns nothing but will throw a RuntimeError for any issues it finds
likely to cause problems in the production system

Definition at line 42 of file Utils.py.

00043                             :
00044     """
00045     _validateProcess_
00046     
00047     Check attributes of process are appropriate for production
00048     This method returns nothing but will throw a RuntimeError for any issues it finds
00049     likely to cause problems in the production system
00050     
00051     """
00052     
00053     schedule=process.schedule_()
00054     paths=process.paths_()
00055     endpaths=process.endpaths_()
00056     
00057     # check output mods are in paths and have appropriate settings
00058     for outputModName in process.outputModules_().keys():
00059         outputMod = getattr(process, outputModName)
00060         if not hasattr(outputMod, 'dataset'):
00061             msg = "Process contains output module without dataset PSET: %s \n" % outputModName
00062             msg += " You need to add this PSET to this module to set dataTier and filterName\n"
00063             raise RuntimeError, msg
00064         ds=getattr(outputMod,'dataset')
00065         if not hasattr(ds, "dataTier"):
00066             msg = "Process contains output module without dataTier parameter: %s \n" % outputModName
00067             msg += " You need to add an untracked parameter to the dataset PSET of this module to set dataTier\n"
00068             raise RuntimeError, msg
00069 
00070         # check module in path or whatever (not sure of exact syntax for endpath)
00071         omRun=False
00072 
00073         if schedule==None:
00074             for path in paths:
00075                 if outputModName in getattr(process,path).moduleNames():
00076                     omRun=True
00077             for path in endpaths:
00078                 if outputModName in getattr(process,path).moduleNames():
00079                     omRun=True
00080         else:
00081             for path in schedule:
00082                 if outputModName in path.moduleNames():
00083                     omRun=True
00084         if omRun==False:
00085             msg = "Output Module %s not in endPath" % outputModName
00086             raise RuntimeError, msg
00087