python.TaskManager.JobAnalyzer Class Reference

Collaboration diagram for python.TaskManager.JobAnalyzer:

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

Public Attributes
	jobDir = jobDir
	dsName = dsName
	taskName = taskName
str	path = jobDir+'/'+dsName+'/'+taskName

Detailed Description

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

Definition at line 672 of file TaskManager.py.

Constructor & Destructor Documentation

__init__()

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

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

python.TaskManager.JobAnalyzer.jobList

(

self

)

Definition at line 683 of file TaskManager.py.

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

jobStatus()

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

Definition at line 691 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 = dsName

Definition at line 677 of file TaskManager.py.

jobDir

python.TaskManager.JobAnalyzer.jobDir = jobDir

Definition at line 676 of file TaskManager.py.

path

str python.TaskManager.JobAnalyzer.path = jobDir+'/'+dsName+'/'+taskName

Definition at line 679 of file TaskManager.py.

taskName

python.TaskManager.JobAnalyzer.taskName = taskName

Definition at line 678 of file TaskManager.py.

---

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

• TaskManager.py