This document describes the current stable version of Celery (5.6). For development docs, go here.

# `celery.loaders.base`

Loader base class.

class celery.loaders.base.BaseLoader(app, **kwargs)

  Base class for loaders.

  Loaders handles,

  > - Reading celery client/worker configurations.

  > - What happens when a task starts?

  >     See `on_task_init()`.

  > - What happens when the worker starts?

  >     See `on_worker_init()`.

  > - What happens when the worker shuts down?

  >     See `on_worker_shutdown()`.

  > - What modules are imported to find tasks?

  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(env='CELERY_CONFIG_MODULE')
  shutdown_worker()
  worker_initialized = False