celery.loaders.base

Базовый класс загрузчика.

classcelery.loaders.base.BaseLoader(app, **kwargs)

Базовый класс для загрузчиков.

Загрузчики отвечают за:

• Чтение конфигураций клиента и рабочего процесса Celery.

• Что происходит при запуске задачи?

  См. on_task_init().

• Что происходит при запуске рабочего процесса?

  См. on_worker_init().

• Что происходит при завершении работы рабочего процесса?

  См. on_worker_shutdown().

• Какие модули импортируются для поиска задач?

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)

propertyconf

Конфигурация загрузчика.

config_from_object(obj, silent=False)

configured=False

propertydefault_modules

find_module(module)

import_default_modules()

import_from_cwd(module, imp=None, package=None)

import_module(module, package=None)

dl>

import_task_module(module)

init_worker()

init_worker_process()

now(utc=True)

on_process_cleanup()

Вызывается после выполнения задачи.

on_task_init(task_id, task)

Вызывается перед выполнением задачи.

on_worker_init()

Вызывается при запуске рабочего процесса (celery worker).

on_worker_process_init()

Вызывается при запуске дочернего процесса.

on_worker_shutdown()

Вызывается при завершении работы рабочего процесса (celery worker).

override_backends={}

read_configuration(env='CELERY_CONFIG_MODULE')

shutdown_worker()

worker_initialized=False