| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- """celery.backends"""
- from functools import partial
- from celery.loaders import settings
- import sys
- DEFAULT_BACKEND = "database"
- DEFAULT_PERIODIC_STATUS_BACKEND = "database"
- CELERY_BACKEND = getattr(settings, "CELERY_BACKEND", DEFAULT_BACKEND)
- CELERY_PERIODIC_STATUS_BACKEND = getattr(settings,
- "CELERY_PERIODIC_STATUS_BACKEND",
- DEFAULT_PERIODIC_STATUS_BACKEND)
- def get_backend_cls(backend):
- """Get backend class by name.
- If the name does not include "``.``" (is not fully qualified),
- ``"celery.backends."`` will be prepended to the name. e.g.
- ``"database"`` becomes ``"celery.backends.database"``.
- """
- if backend.find(".") == -1:
- backend = "celery.backends.%s" % backend
- __import__(backend)
- backend_module = sys.modules[backend]
- return getattr(backend_module, "Backend")
- """
- .. function:: get_default_backend_cls()
- Get the backend class specified in :setting:`CELERY_BACKEND`.
- """
- get_default_backend_cls = partial(get_backend_cls, CELERY_BACKEND)
- """
- .. function:: get_default_periodicstatus_backend_cls()
- Get the backend class specified in
- :setting:`CELERY_PERIODIC_STATUS_BACKEND`.
- """
- get_default_periodicstatus_backend_cls = partial(get_backend_cls,
- CELERY_PERIODIC_STATUS_BACKEND)
- """
- .. class:: DefaultBackend
- The default backend class used for storing task results and status,
- specified in :setting:`CELERY_BACKEND`.
- """
- DefaultBackend = get_default_backend_cls()
- """
- .. class:: DefaultPeriodicStatusBackend
- The default backend for storing periodic task metadata, specified
- in :setting:`CELERY_PERIODIC_STATUS_BACKEND`.
- """
- DefaultPeriodicStatusBackend = get_default_periodicstatus_backend_cls()
- """
- .. data:: default_backend
- An instance of :class:`DefaultBackend`.
- """
- default_backend = DefaultBackend()
- """
- .. data:: default_periodic_status_backend
- An instance of :class:`DefaultPeriodicStatusBackend`.
- """
- default_periodic_status_backend = DefaultPeriodicStatusBackend()
|
