in core/__init__.py [0:0]
def sync_logger_config(logger, config):
elastic_pipes_logger = logging.getLogger("elastic.pipes")
if logger == elastic_pipes_logger:
return
for handler in reversed(logger.handlers):
logger.removeHandler(handler)
for handler in elastic_pipes_logger.handlers:
logger.addHandler(handler)
level = get_node(config, "logging.level", None)
if level is None or getattr(elastic_pipes_logger, "overridden", False):
logger.setLevel(elastic_pipes_logger.level)
else:
logger.setLevel(level.upper())