Source code for intranet.celery

import logging
import os

from celery import Celery
from celery.signals import after_setup_logger, after_setup_task_logger

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "intranet.settings")

app = Celery("intranet")
app.config_from_object("django.conf:settings", namespace="CELERY")
app.autodiscover_tasks()


[docs]@after_setup_logger.connect
@after_setup_task_logger.connect
def setup_logger(logger, **kwargs):  # pylint: disable=unused-argument
    from django.conf import settings  # pylint: disable=import-outside-toplevel

    logger.level = getattr(logging, settings.LOG_LEVEL)