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 12 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 25 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 83 of file testIfMatch.py.

matrix

python.testIfMatch.matrix

Definition at line 65 of file testIfMatch.py.

outDict

python.testIfMatch.outDict

Definition at line 53 of file testIfMatch.py.

tag

python.testIfMatch.tag

Definition at line 50 of file testIfMatch.py.

taskNames

python.testIfMatch.taskNames

Definition at line 59 of file testIfMatch.py.