python.TaskManager.JobAnalyzer Class Reference

Collaboration diagram for python.TaskManager.JobAnalyzer:

Public Member Functions
def	__init__ (self, jobDir, dsName, taskName)
def	jobList (self)
def	jobStatus (self, jobName)

Public Attributes
	jobDir
	dsName
	taskName
	path

Detailed Description

JobAnalyzer is a class for analyzing the jobs of a given task.

Definition at line 674 of file TaskManager.py.

Constructor & Destructor Documentation

__init__()

def python.TaskManager.JobAnalyzer.__init__	(		self,
			jobDir,
			dsName,
			taskName
	)

Definition at line 677 of file TaskManager.py.

    def __init__(self,jobDir,dsName,taskName):
        self.jobDir = jobDir
        self.dsName = dsName
        self.taskName = taskName
        self.path = jobDir+'/'+dsName+'/'+taskName
        #self.maxWallTime = 5*86400   # max time job should be running in s
 
 

Member Function Documentation

jobList()

def python.TaskManager.JobAnalyzer.jobList

(

self

)

Definition at line 685 of file TaskManager.py.

    def jobList(self):
        try:
            l = os.listdir(self.path)
        except Exception:
            l = []
        return l
 
 

jobStatus()

def python.TaskManager.JobAnalyzer.jobStatus	(		self,
			jobName
	)

Definition at line 693 of file TaskManager.py.

    def jobStatus(self,jobName):
        status = TaskManager.StatusCodes['UNKNOWN']
        exitcode = ''
        p = self.path+'/'+jobName
        if os.path.exists(p):
            if glob.glob(p+'/*.config.py'):
                status = TaskManager.StatusCodes['CONFIGURED']
            if glob.glob(p+'/*.SUBMITTED'):
                status = TaskManager.StatusCodes['SUBMITTED']
            # Protect against jobs dying w/o updating time stamp files - must be
            # accompanied by similar protection in TaskAnalyzer
            #r = glob.glob(p+'/*.RUNNING'):
            #if r:
            #    status = TaskManager.StatusCodes['RUNNING']
            #    if len(r)==1 &&  (time.time()-os.path.getctime(r[0]))>self.maxWallTime:
            #        status = TaskManager.StatusCodes['FAILED']
            if glob.glob(p+'/*.RUNNING'):
                status = TaskManager.StatusCodes['RUNNING']
            if glob.glob(p+'/*.POSTPROCESSING'):
                status = TaskManager.StatusCodes['POSTPROCESSING']
            if glob.glob(p+'/*.COMPLETED'):
                status = TaskManager.StatusCodes['COMPLETED']
                # Check if job completed w/o producing an exit status
                if len(glob.glob(p+'/*.exit.0'))==0:
                    status = TaskManager.StatusCodes['FAILED']
            try:
                exitcode = open(glob.glob(p+'/*.exitstatus.dat')[0]).read()
            except Exception:
                pass
            if len(glob.glob(p+'/*.exit.*'))>len(glob.glob(p+'/*.exit.0')):
                status = TaskManager.StatusCodes['FAILED']
        return (status,exitcode)
 
 
#
# Test code for modules
#

Member Data Documentation

dsName

python.TaskManager.JobAnalyzer.dsName

Definition at line 679 of file TaskManager.py.

jobDir

python.TaskManager.JobAnalyzer.jobDir

Definition at line 678 of file TaskManager.py.

path

python.TaskManager.JobAnalyzer.path

Definition at line 681 of file TaskManager.py.

taskName

python.TaskManager.JobAnalyzer.taskName

Definition at line 680 of file TaskManager.py.

---

The documentation for this class was generated from the following file:

• TaskManager.py