l.s.j.r.TwistedJobRunner(BaseJobRunner) : class documentation

Part of lp.services.job.runner View In Hierarchy

Run Jobs via twisted.
Method __init__ Undocumented
Method runJobInSubprocess Run the job_class with the specified id in the process pool.
Method runAll Run all ready jobs.
Method terminated Callback to stop the processpool and reactor.
Method failed Callback for when the job fails.
Class Method runFromSource Run all ready jobs provided by the specified source.
Method _logTimeout Undocumented

Inherited from BaseJobRunner:

Method acquireLease Undocumented
Method runJob Undocumented
Method runJobHandleError Undocumented
Method userErrorTypes Undocumented
Method retryErrorTypes Undocumented
Method _doOops Report an OOPS for the provided job and info.
Method _logOopsId Report oopses by id to the log.
def __init__(self, job_source, dbuser, logger=None, error_utility=None):
overrides lp.services.job.runner.BaseJobRunner.__init__
Undocumented
def runJobInSubprocess(self, job):
Run the job_class with the specified id in the process pool.
Returnsa Deferred that fires when the job has completed.
def _logTimeout(self, job):
Undocumented
@inlineCallbacks
def runAll(self):
Run all ready jobs.
def terminated(self, ignored=None):
Callback to stop the processpool and reactor.
def failed(self, failure):
Callback for when the job fails.
@classmethod
def runFromSource(cls, job_source, dbuser, logger, _log_twisted=False): 
Run all ready jobs provided by the specified source.

The dbuser parameter is not ignored.
:param _log_twisted: For debugging: If True, emit verbose Twisted
    messages to stderr.
API Documentation for Launchpad, generated by pydoctor at 2022-06-16 00:00:12.