simple_cluster.JobQueueManager Class Reference

List of all members.

Public Member Functions
def	__init__
def	addJob
def	clearJobs
def	getOutputJobs
def	getAllJobs
def	executeQueue
Private Member Functions
def	_checkForCompletedJobs
Private Attributes
	__cluster
	__inputQueue
	__outputQueue

---

Detailed Description

Definition at line 2798 of file simple_cluster.py.

---

Constructor & Destructor Documentation

def simple_cluster.JobQueueManager.__init__	(		self,
			cluster = None
	)

Definition at line 2799 of file simple_cluster.py.

---

Member Function Documentation

def simple_cluster.JobQueueManager._checkForCompletedJobs	(		self,
			engineList
	)		[private]

This method will look at all jobs in the status, if they are
marked as done it will:
   * update the outputQueue
   * add the engine back to the engine list
   * remove the report from the status

Definition at line 2886 of file simple_cluster.py.

References simple_cluster.JobQueueManager.__outputQueue.

Referenced by simple_cluster.JobQueueManager.executeQueue().

def simple_cluster.JobQueueManager.addJob	(		self,
			jobData
	)

Add another JobData object to the queue of jobs to be executed.

Definition at line 2808 of file simple_cluster.py.

def simple_cluster.JobQueueManager.clearJobs

(

self

)

Remove all jobs from the queue, this is usually a good idea
before reusing a JobQueueManager.

Definition at line 2819 of file simple_cluster.py.

References simple_cluster.JobQueueManager.__inputQueue, and simple_cluster.JobQueueManager.__outputQueue.

def simple_cluster.JobQueueManager.executeQueue

(

self

)

This method causes all jobs to be executed on the available engines
It will block until the jobs are complete.

Definition at line 2845 of file simple_cluster.py.

References simple_cluster.JobQueueManager.__inputQueue, simple_cluster.JobQueueManager.__outputQueue, simple_cluster.JobQueueManager._checkForCompletedJobs(), and backend_demo.pop.

def simple_cluster.JobQueueManager.getAllJobs

(

self

)

Definition at line 2842 of file simple_cluster.py.

def simple_cluster.JobQueueManager.getOutputJobs	(		self,
			status = None
	)

This returns all jobs in the output queue which
match the specified status.  If no status is specified
the entire list of output jobs is returned.

Definition at line 2827 of file simple_cluster.py.

---

Member Data Documentation

simple_cluster.JobQueueManager.__cluster [private]

Definition at line 2800 of file simple_cluster.py.

simple_cluster.JobQueueManager.__inputQueue [private]

Definition at line 2805 of file simple_cluster.py.

Referenced by simple_cluster.JobQueueManager.clearJobs(), and simple_cluster.JobQueueManager.executeQueue().

simple_cluster.JobQueueManager.__outputQueue [private]

Definition at line 2806 of file simple_cluster.py.

Referenced by simple_cluster.JobQueueManager._checkForCompletedJobs(), simple_cluster.JobQueueManager.clearJobs(), and simple_cluster.JobQueueManager.executeQueue().

---

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

• simple_cluster.py