l.s.j.celeryjob : module documentation

Part of lp.services.job

Celery-specific Job code.

Because celery sets up configuration at import time, code that is not designed to use Celery may break if this is used.

Class CeleryRunJob The Celery Task that runs a job.
Function celery_run_job Undocumented
Function celery_run_job_ignore_result Undocumented
Class FindMissingReady Undocumented
Function find_missing_ready Find ready jobs that are not queued.
Class PrefixedTask A Task with more informative task_id defaults.
Function run_missing_ready Task to run any jobs that are ready but not scheduled.
Function ensure_zcml Ensure the zcml has been executed for the current process.
Function task_init Prepare to run a task.
@celery_app.task(CeleryRunJob, True)
def celery_run_job(self, job_id, dbuser):
Undocumented
@celery_app.task(CeleryRunJob, True, True)
def celery_run_job_ignore_result(self, job_id, dbuser):
Undocumented
def find_missing_ready(job_source):
Find ready jobs that are not queued.
@celery_app.task(PrefixedTask, 'RunMissingReady', True)
def run_missing_ready(_no_init=False):
Task to run any jobs that are ready but not scheduled.

Currently supports only BranchScanJob. :param _no_init: For tests. If True, do not perform the initialization.

def ensure_zcml():
Ensure the zcml has been executed for the current process.
def task_init(dbuser):
Prepare to run a task.
ParametersdbuserThe database user to use for running the task.
API Documentation for Launchpad, generated by pydoctor at 2020-08-07 00:00:07.