JobAnalyzer is a class for analyzing the jobs of a given task.
Definition at line 672 of file TaskManager.py.
◆ __init__()
def python.TaskManager.JobAnalyzer.__init__ |
( |
|
self, |
|
|
|
jobDir, |
|
|
|
dsName, |
|
|
|
taskName |
|
) |
| |
Definition at line 675 of file TaskManager.py.
675 def __init__(self,jobDir,dsName,taskName):
678 self.taskName = taskName
679 self.path = jobDir+
'/'+dsName+
'/'+taskName
◆ jobList()
def python.TaskManager.JobAnalyzer.jobList |
( |
|
self | ) |
|
◆ jobStatus()
def python.TaskManager.JobAnalyzer.jobStatus |
( |
|
self, |
|
|
|
jobName |
|
) |
| |
Definition at line 691 of file TaskManager.py.
691 def jobStatus(self,jobName):
692 status = TaskManager.StatusCodes[
'UNKNOWN']
694 p = self.path+
'/'+jobName
695 if os.path.exists(p):
696 if glob.glob(p+
'/*.config.py'):
697 status = TaskManager.StatusCodes[
'CONFIGURED']
698 if glob.glob(p+
'/*.SUBMITTED'):
699 status = TaskManager.StatusCodes[
'SUBMITTED']
707 if glob.glob(p+
'/*.RUNNING'):
708 status = TaskManager.StatusCodes[
'RUNNING']
709 if glob.glob(p+
'/*.POSTPROCESSING'):
710 status = TaskManager.StatusCodes[
'POSTPROCESSING']
711 if glob.glob(p+
'/*.COMPLETED'):
712 status = TaskManager.StatusCodes[
'COMPLETED']
714 if len(glob.glob(p+
'/*.exit.0'))==0:
715 status = TaskManager.StatusCodes[
'FAILED']
717 exitcode =
open(glob.glob(p+
'/*.exitstatus.dat')[0]).
read()
720 if len(glob.glob(p+
'/*.exit.*'))>len(glob.glob(p+
'/*.exit.0')):
721 status = TaskManager.StatusCodes[
'FAILED']
722 return (status,exitcode)
◆ dsName
python.TaskManager.JobAnalyzer.dsName |
◆ jobDir
python.TaskManager.JobAnalyzer.jobDir |
◆ path
python.TaskManager.JobAnalyzer.path |
◆ taskName
python.TaskManager.JobAnalyzer.taskName |
The documentation for this class was generated from the following file: