python.batchstatus.BatchStatus Class Reference

Public Member Functions
def	__init__ (self, projects)
def	update (self, projects)
def	get_stage_status (self, stagename)

Static Public Member Functions
def	update_jobs ()
def	get_jobs ()

Public Attributes
	projects
	stage_stats

Detailed Description

Definition at line 32 of file batchstatus.py.

Constructor & Destructor Documentation

def python.batchstatus.BatchStatus.__init__	(		self,
			projects
	)

Definition at line 36 of file batchstatus.py.

    def __init__(self, projects):

        # Initialize attributes.

        self.projects = projects

        # The status for each stage is a 4-tuple of integers consisting
        # of the following values.
        # 1. Number of idle batch jobs (state 'I')
        # 2. Number of running batch jobs (state 'R')
        # 3. Number of held batch jobs (state 'H')
        # 4. Number of batch jobs in any other stage.

        self.stage_stats = {}
        self.update(projects)
        

Member Function Documentation

def python.batchstatus.BatchStatus.get_jobs ( )

static

Definition at line 121 of file batchstatus.py.

    def get_jobs():

        global jobs
        return jobs    

def python.batchstatus.BatchStatus.get_stage_status	(		self,
			stagename
	)

Definition at line 129 of file batchstatus.py.

    def get_stage_status(self, stagename):
        return self.stage_stats[stagename]

def python.batchstatus.BatchStatus.update	(		self,
			projects
	)

Definition at line 55 of file batchstatus.py.

    def update(self, projects):

        global jobs, server

        for project in projects:
            if project.server != '-' and project.server != '':
                server = project.server
            for stage in project.stages:
                self.stage_stats[stage.name] = [0, 0, 0, 0]

        # Get information from the batch system.

        if jobs == None:
            BatchStatus.update_jobs()
        for job in jobs:
            words = job.split()
            if len(words) > 4:
                state = words[-4]
                script = words[-1]

                # Loop over stages.

                for project in projects:
                    for stage in project.stages:
                        workscript = '%s-%s-%s.sh' % (stage.name, project.name, project.release_tag)
                        if script.find(workscript) == 0:
                            if state == 'I':
                                self.stage_stats[stage.name][0] = \
                                self.stage_stats[stage.name][0] + 1
                            elif state == 'R':
                                self.stage_stats[stage.name][1] = \
                                self.stage_stats[stage.name][1] + 1
                            elif state == 'H':
                                self.stage_stats[stage.name][2] = \
                                self.stage_stats[stage.name][2] + 1
                            else:
                                self.stage_stats[stage.name][3] = \
                                self.stage_stats[stage.name][3] + 1

def python.batchstatus.BatchStatus.update_jobs ( )

static

Definition at line 97 of file batchstatus.py.

    def update_jobs():

        global jobs, server

        command = ['jobsub_q']
        if server != None:
            command.append('--jobsub-server=%s' % server)
        command.append('--group=%s' % project_utilities.get_experiment())
        command.append('--user=%s' % project_utilities.get_user())
        command.append('--role=%s' % project_utilities.get_role())
        jobinfo = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
        jobout, joberr = jobinfo.communicate()
        jobout = convert_str(jobout)
        joberr = convert_str(joberr)
        rc = jobinfo.poll()
        if rc != 0:
            #raise JobsubError(command, rc, jobout, joberr)
            # Simply return in case jobsub_q fails.
            return
        jobs = jobout.split('\n')

Member Data Documentation

python.batchstatus.BatchStatus.projects

Definition at line 40 of file batchstatus.py.

python.batchstatus.BatchStatus.stage_stats

Definition at line 49 of file batchstatus.py.

---

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

• larbatch/python/batchstatus.py

---

Generated by   1.8.11