Trees       Indices       Help   
Ganeti
Package ganeti :: Package jqueue :: Class _JobDependencyManager
[hide private]
[frames] | no frames]

Class _JobDependencyManager

source code

Keeps track of job dependencies.

Instance Methods [hide private]
 
__init__(self, getstatus_fn)
Initializes this class.		 source code
 
JobWaiting(self, job)
Checks if a job is waiting.		 source code
 
CheckAndRegister(self, job, dep_job_id, dep_status)
Checks if a dependency job has the requested status.		 source code
 
_RemoveEmptyWaitersUnlocked(self)
Remove all jobs without actual waiters.		 source code
Method Details [hide private]

CheckAndRegister(self, job, dep_job_id, dep_status)

source code 

Checks if a dependency job has the requested status.

If the other job is not yet in a finalized status, the calling job will be notified (re-added to the workerpool) at a later point.

Parameters:
  • job (_QueuedJob) - Job object
  • dep_job_id (int) - ID of dependency job
  • dep_status (list) - Required status

   Trees       Indices       Help   
Ganeti
Generated by Epydoc 3.0.1 on Mon Apr 4 13:43:57 2016 http://epydoc.sourceforge.net