ganeti.jqueue._JobDependencyManager

class documentation

class _JobDependencyManager(object):

View In Hierarchy

Keeps track of job dependencies.

Method __init__ Initializes this class.
Method CheckAndRegister Checks if a dependency job has the requested status.
Method JobWaiting Checks if a job is waiting.
Constant CANCEL Undocumented
Constant CONTINUE Undocumented
Constant ERROR Undocumented
Constant WAIT Undocumented
Constant WRONGSTATUS Undocumented
Method _RemoveEmptyWaitersUnlocked Remove all jobs without actual waiters.
Instance Variable _getstatus_fn Undocumented
Instance Variable _waiters Undocumented
def __init__(self, getstatus_fn):

Initializes this class.

def CheckAndRegister(self, job, dep_job_id, dep_status):

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:_QueuedJobJob object
dep_job_id:intID of dependency job
dep_status:listRequired status
def JobWaiting(self, job):

Checks if a job is waiting.

CANCEL =

Undocumented

CONTINUE =

Undocumented

ERROR =

Undocumented

WAIT =

Undocumented

WRONGSTATUS =

Undocumented

def _RemoveEmptyWaitersUnlocked(self):

Remove all jobs without actual waiters.

_getstatus_fn =

Undocumented

_waiters: dict =

Undocumented