python.testIfMatch Namespace Reference

Functions
def	getOutputDictFromAMI (tag)
def	getTaskNamesFromCastor ()

Variables
	tag
	outDict
	taskNames
	matrix
	end

Function Documentation

getOutputDictFromAMI()

def python.testIfMatch.getOutputDictFromAMI

(

tag

)

Definition at line 13 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()

def python.testIfMatch.getTaskNamesFromCastor

(

)

Definition at line 26 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 84 of file testIfMatch.py.

matrix

python.testIfMatch.matrix

Definition at line 66 of file testIfMatch.py.

outDict

python.testIfMatch.outDict

Definition at line 54 of file testIfMatch.py.

tag

python.testIfMatch.tag

Definition at line 51 of file testIfMatch.py.

taskNames

python.testIfMatch.taskNames

Definition at line 60 of file testIfMatch.py.