l.s.j.celeryjob : module documentation

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.

Parameters dbuser The database user to use for running the task.

API Documentation for Launchpad, generated by pydoctor at 2022-06-16 00:00:12.