ewoksjob.config.EwoksLoader#

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

Bases: Loader

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]#

Read configuration from celeryconfig.py.

Return type:

dict

setup_settings(settingsdict)#
shutdown_worker()#
worker_initialized = False#