diff options
| author | Florian Perucki <florian.perucki@gmail.com> | 2020-01-19 12:30:46 +0100 |
|---|---|---|
| committer | Selwin Ong <selwin.ong@gmail.com> | 2020-01-19 18:30:46 +0700 |
| commit | 37a6304a4f7db6a86c8e9216beb3214e6f716640 (patch) | |
| tree | 0fb9e66769c0bd475f513feeaf441bddf32b3193 | |
| parent | baa0cc268adff31f22e0278e2c76cf26c5a2d14c (diff) | |
| download | rq-37a6304a4f7db6a86c8e9216beb3214e6f716640.tar.gz | |
fix: use correct logging handler for scheduler (#1178)
| -rw-r--r-- | rq/logutils.py | 4 | ||||
| -rw-r--r-- | rq/scheduler.py | 9 |
2 files changed, 9 insertions, 4 deletions
diff --git a/rq/logutils.py b/rq/logutils.py index 2ae417a..2d849c1 100644 --- a/rq/logutils.py +++ b/rq/logutils.py @@ -10,8 +10,8 @@ from rq.defaults import (DEFAULT_LOGGING_FORMAT, def setup_loghandlers(level=None, date_format=DEFAULT_LOGGING_DATE_FORMAT, - log_format=DEFAULT_LOGGING_FORMAT): - logger = logging.getLogger('rq.worker') + log_format=DEFAULT_LOGGING_FORMAT, name='rq.worker'): + logger = logging.getLogger(name) if not _has_effective_handler(logger): formatter = logging.Formatter(fmt=log_format, datefmt=date_format) diff --git a/rq/scheduler.py b/rq/scheduler.py index d4ebec5..f269ea9 100644 --- a/rq/scheduler.py +++ b/rq/scheduler.py @@ -11,13 +11,18 @@ from .job import Job from .queue import Queue from .registry import ScheduledJobRegistry from .utils import current_timestamp, enum +from .logutils import setup_loghandlers SCHEDULER_KEY_TEMPLATE = 'rq:scheduler:%s' SCHEDULER_LOCKING_KEY_TEMPLATE = 'rq:scheduler-lock:%s' -format = "%(asctime)s: %(message)s" -logging.basicConfig(format=format, level=logging.INFO, datefmt="%H:%M:%S") +setup_loghandlers( + level=logging.INFO, + name="rq.scheduler", + log_format="%(asctime)s: %(message)s", + date_format="%H:%M:%S" +) class RQScheduler(object): |
