runTheMatrix Namespace Reference

Functions
def	runSelected
def	showRaw
def	stepOrIndex

Variables
string	action = 'store_true'
list	choices = ['init','test','submit','force']
int	default = 4
string	dest = 'nThreads'
string	help = 'number of threads. 0 Will use 4 threads, not execute anything but create the wfs'
	mapped = False
tuple	parser = optparse.OptionParser(usage)
dictionary	predefinedSet
tuple	ret = showRaw(opt)
	prodAgent to be discontinued More...
list	testList = []
string	usage = 'usage: runTheMatrix.py --show -s '

Function Documentation

def runTheMatrix.runSelected

(

opt

)

Definition at line 20 of file runTheMatrix.py.

def runSelected(opt):

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

    ret = 0
    if opt.show:
        mrd.show(opt.testList,opt.extended)
        if opt.testList : print 'testListected items:', opt.testList
    else:
        mRunnerHi = MatrixRunner(mrd.workFlows, 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

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