diff --git a/features/environment.py b/features/environment.py index 79db5d16..1f36eb0c 100644 --- a/features/environment.py +++ b/features/environment.py @@ -245,6 +245,10 @@ class PatroniController(AbstractController): self.recursive_update(config, custom_config) self.recursive_update(config, { + 'log': { + 'format': '%(asctime)s %(levelname)s [%(pathname)s:%(lineno)d - %(funcName)s]: %(message)s', + 'loggers': {'patroni.postgresql.callback_executor': 'DEBUG'} + }, 'bootstrap': { 'dcs': { 'loop_wait': 2, diff --git a/patroni/postgresql/callback_executor.py b/patroni/postgresql/callback_executor.py index fa645b86..06b9f353 100644 --- a/patroni/postgresql/callback_executor.py +++ b/patroni/postgresql/callback_executor.py @@ -1,8 +1,9 @@ import logging +import sys from enum import Enum from threading import Condition, Thread -from typing import List +from typing import Any, Dict, List from .cancellable import CancellableExecutor, CancellableSubprocess @@ -53,6 +54,8 @@ class CallbackExecutor(CancellableExecutor, Thread): If it couldn't be killed we wait until it finishes. :param cmd: command to be executed""" + kwargs: Dict[str, Any] = {'stacklevel': 3} if sys.version_info >= (3, 8) else {} + logger.debug('CallbackExecutor.call(%s)', cmd, **kwargs) if cmd[-3] == CallbackAction.ON_RELOAD: return self._on_reload_executor.call_nowait(cmd)