python.testIfMatch Namespace Reference

Functions
	getOutputDictFromAMI (tag)
	getTaskNamesFromCastor ()

Variables
	tag = sys.argv[1]
	outDict = getOutputDictFromAMI(tag)
	taskNames = getTaskNamesFromCastor()
	matrix = dict()
	end

Function Documentation

getOutputDictFromAMI()

python.testIfMatch.getOutputDictFromAMI

(

tag

)

Definition at line 10 of file testIfMatch.py.

def getOutputDictFromAMI(tag):
    try:
        from pyAMI.pyAMI import AMI
        amires = AMI().execute(["ListConfigurationTag","-configTag=%s" % tag])
        d = amires.getDict()['rowset_%s'%tag][tag]
        outDict = eval(d.get('outputs','None'))
    except Exception as e:
        print ("Failed to get OutputDict from AMI")
        print (e)
        return None
    return outDict
 
 

getTaskNamesFromCastor()

python.testIfMatch.getTaskNamesFromCastor

(

)

Definition at line 23 of file testIfMatch.py.

def getTaskNamesFromCastor():
    #cdirs=("/castor/cern.ch/grid/atlas/tzero/prod1/perm/data11_7TeV","/castor/cern.ch/grid/atlas/tzero/prod1/perm/data11_cos")
    cdirs=("/castor/cern.ch/grid/atlas/tzero/prod1/perm/data11_hi","/castor/cern.ch/grid/atlas/tzero/prod1/perm/data11_7TeV")
 
    tasknames=set()
    for d in cdirs:
        proj=d.split("/")[-1]
        cmd="nsls "+d
        (stat,out)=subprocess.getstatusoutput(cmd)
        if stat!=0:
            print ("ERROR, could not get list of streams from castor directory",d)
            print (out)
            return None
        for stream in out.split(os.linesep):
            tasknames.add(proj+".00000000."+stream+".merge.RAW")
    return tasknames
 
 
 

Variable Documentation

end

python.testIfMatch.end

Definition at line 81 of file testIfMatch.py.

matrix

python.testIfMatch.matrix = dict()

Definition at line 63 of file testIfMatch.py.

outDict

python.testIfMatch.outDict = getOutputDictFromAMI(tag)

Definition at line 51 of file testIfMatch.py.

tag

python.testIfMatch.tag = sys.argv[1]

Definition at line 48 of file testIfMatch.py.

taskNames

python.testIfMatch.taskNames = getTaskNamesFromCastor()

Definition at line 57 of file testIfMatch.py.