runTheMatrix Namespace Reference

Classes
class	TheMatrix

Functions
def	runSelected
def	showRaw
def	stepOrIndex

Variables
string	action = 'store_true'
list	choices = ['init','test','submit','force']
tuple	cmssw_base = os.getenv(cmssw_env,None)
string	const = 'required'
tuple	cudart_basename = os.path.basename(libcudart)
	cudart_version = None
string	default = ''
string	dest = 'batchName'
tuple	gpugroup = parser.add_argument_group('GPU-related options','These options are only meaningful when --gpu is used, and is not set to forbidden.')
string	help = 'relval batch: suffix to be appended to Campaign name'
tuple	ibeos_cache = os.path.join(os.getenv("LOCALRT"), "ibeos_cache.txt")
tuple	libcudart = os.path.realpath(os.path.expandvars('$CMSSW_RELEASE_BASE/external/$SCRAM_ARCH/lib/libcudart.so'))
	mapped = False
string	nargs = '?'
tuple	opt = parser.parse_args()
tuple	parser = argparse.ArgumentParser(usage,formatter_class=argparse.ArgumentDefaultsHelpFormatter)
dictionary	predefinedSet
tuple	ret = showRaw(opt)
	prodAgent to be discontinued More...
list	testList = []
	type = int,
string	usage = 'usage: runTheMatrix.py --show -s '

Function Documentation

def runTheMatrix.runSelected

(

opt

)

Definition at line 20 of file runTheMatrix.py.

References join(), and print().

def runSelected(opt):

    mrd = MatrixReader(opt)
    mrd.prepare(opt.useInput, opt.refRel, opt.fromScratch)

    # test for wrong input workflows
    if opt.testList:
        definedWf = [dwf.numId for dwf in mrd.workFlows]
        definedSet = set(definedWf)
        testSet = set(opt.testList)
        undefSet = testSet - definedSet
        if len(undefSet)>0: raise ValueError('Undefined workflows: '+', '.join(map(str,list(undefSet))))
        duplicates = [wf for wf in testSet if definedWf.count(wf)>1 ]
        if len(duplicates)>0: raise ValueError('Duplicated workflows: '+', '.join(map(str,list(duplicates))))

    ret = 0
    if opt.show:
        mrd.show(opt.testList, opt.extended, opt.cafVeto)
        if opt.testList : print('testListected items:', opt.testList)
    else:
        mRunnerHi = MatrixRunner(mrd.workFlows, opt.nProcs, opt.nThreads)
        ret = mRunnerHi.runTests(opt)

    if opt.wmcontrol:
        if ret!=0:
            print('Cannot go on with wmagent injection with failing workflows')
        else:
            wfInjector = MatrixInjector(opt,mode=opt.wmcontrol,options=opt.wmoptions)
            ret= wfInjector.prepare(mrd,
                                    mRunnerHi.runDirs)
            if ret==0:
                wfInjector.upload()
                wfInjector.submit()
    return ret

# ================================================================================