ewoksjob.config.EwoksLoader

class ewoksjob.config.EwoksLoader(app)[source]

Bases: BaseLoader

Celery loader based on a configuration URI: python file, python module, yaml file, Beacon URL.

Requires the environment variable CELERY_LOADER=ewoksjob.config.EwoksLoader

Parameters:

app (Celery) –

autodiscover_tasks(packages, related_name='tasks')
builtin_modules = frozenset({})
cmdline_config_parser(args, namespace='celery', re_type=re.compile('\\((\\w+)\\)'), extra_types=None, override_types=None)
property conf

Loader configuration.

config_from_object(obj, silent=False)
configured = False
property default_modules
find_module(module)
import_default_modules()
import_from_cwd(module, imp=None, package=None)
import_module(module, package=None)
import_task_module(module)
init_worker()
init_worker_process()
now(utc=True)
on_process_cleanup()

Called after a task is executed.

on_task_init(task_id, task)

Called before a task is executed.

on_worker_init()

Called when the worker (celery worker) starts.

on_worker_process_init()

Called when a child process starts.

on_worker_shutdown()

Called when the worker (celery worker) shuts down.

override_backends = {}
read_configuration()[source]
Return type:

dict

shutdown_worker()
worker_initialized = False