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 = {}¶
- setup_settings(settingsdict)¶
- shutdown_worker()¶
- worker_initialized = False¶