ganeti.tools.burnin.JobHandler

class documentation

class JobHandler(FeedbackAccumulator):

Known subclasses: ganeti.tools.burnin.Burner

View In Hierarchy

Class for handling Ganeti jobs.

Method __init__ Undocumented
Method CommitQueue Execute all submitted opcodes in case of parallel burnin
Method ExecJobSet Execute a set of jobs and return once all are done.
Method ExecOp Execute one or more opcodes and manage the exec buffer.
Method ExecOrQueue Execute an opcode and manage the exec buffer.
Method MaybeRetry Possibly retry a given function execution.
Method StartBatch Start a new batch of jobs.
Instance Variable cl Undocumented
Instance Variable queue_retry Undocumented
Instance Variable queued_ops Undocumented
Method _ExecOp Execute one or more opcodes and manage the exec buffer.

Inherited from FeedbackAccumulator:

Method ClearFeedbackBuf Clear the feedback buffer.
Method Feedback Acumulate feedback in our buffer.
Method GetFeedbackBuf Return the contents of the buffer.
Class Variable opts Undocumented
Class Variable _feed_buf Undocumented
def __init__(self):
overridden in ganeti.tools.burnin.Burner

Undocumented

def CommitQueue(self):

Execute all submitted opcodes in case of parallel burnin

def ExecJobSet(self, jobs):

Execute a set of jobs and return once all are done.

The method will return the list of results, if all jobs are successful. Otherwise, OpExecError will be raised from within cli.py.

def ExecOp(self, retry, *ops):

Execute one or more opcodes and manage the exec buffer.

Returns
if only opcode has been passed, we return its result; otherwise we return the list of results
def ExecOrQueue(self, name, ops, post_process=None):

Execute an opcode and manage the exec buffer.

def MaybeRetry(self, retry_count, msg, fn, *args):

Possibly retry a given function execution.

Parameters
retry_count:int

retry counter:

  • 0: non-retryable action
  • 1: last retry for a retryable action
  • MAX_RETRIES: original try for a retryable action
msg:strthe kind of the operation
fn:callablethe function to be called
*argsUndocumented
def StartBatch(self, retry):

Start a new batch of jobs.

Parameters
retrywhether this is a retryable batch
cl =

Undocumented

queue_retry =

Undocumented

queued_ops: list =

Undocumented

def _ExecOp(self, *ops):

Execute one or more opcodes and manage the exec buffer.

Returns
if only opcode has been passed, we return its result; otherwise we return the list of results