Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/celery_backend/config.py
| # Copyright (C) 2015 The Software Heritage developers | # Copyright (C) 2015 The Software Heritage developers | ||||
| # See the AUTHORS file at the top-level directory of this distribution | # See the AUTHORS file at the top-level directory of this distribution | ||||
| # License: GNU General Public License version 3, or any later version | # License: GNU General Public License version 3, or any later version | ||||
| # See top-level LICENSE file for more information | # See top-level LICENSE file for more information | ||||
| import logging | import logging | ||||
| import os | import os | ||||
| from celery import Celery | from celery import Celery | ||||
| from celery.signals import setup_logging | from celery.signals import setup_logging | ||||
| from celery.utils.log import ColorFormatter | |||||
| from celery.worker.control import Panel | from celery.worker.control import Panel | ||||
| from kombu import Exchange, Queue | from kombu import Exchange, Queue | ||||
| from kombu.five import monotonic as _monotonic | from kombu.five import monotonic as _monotonic | ||||
| from swh.core.config import load_named_config | from swh.core.config import load_named_config | ||||
| from swh.core.logger import JournalHandler | from swh.core.logger import JournalHandler | ||||
| Show All 21 Lines | def setup_log_handler(loglevel=None, logfile=None, format=None, | ||||
| if loglevel is None: | if loglevel is None: | ||||
| loglevel = logging.DEBUG | loglevel = logging.DEBUG | ||||
| formatter = logging.Formatter(format) | formatter = logging.Formatter(format) | ||||
| root_logger = logging.getLogger('') | root_logger = logging.getLogger('') | ||||
| root_logger.setLevel(logging.INFO) | root_logger.setLevel(logging.INFO) | ||||
| if loglevel == logging.DEBUG: | |||||
| color_formatter = ColorFormatter(format) if colorize else formatter | |||||
| console = logging.StreamHandler() | |||||
| console.setLevel(logging.DEBUG) | |||||
| console.setFormatter(color_formatter) | |||||
| root_logger.addHandler(console) | |||||
| systemd_journal = JournalHandler() | systemd_journal = JournalHandler() | ||||
| systemd_journal.setLevel(logging.DEBUG) | systemd_journal.setLevel(logging.DEBUG) | ||||
| systemd_journal.setFormatter(formatter) | systemd_journal.setFormatter(formatter) | ||||
| root_logger.addHandler(systemd_journal) | root_logger.addHandler(systemd_journal) | ||||
| celery_logger = logging.getLogger('celery') | celery_logger = logging.getLogger('celery') | ||||
| celery_logger.setLevel(logging.INFO) | celery_logger.setLevel(logging.INFO) | ||||
| ▲ Show 20 Lines • Show All 94 Lines • Show Last 20 Lines | |||||