in core/util.py [0:0]
def setup_logging(default_level="NOTSET"):
def _handler(level):
import logging
formatter = logging.Formatter("%(name)s - %(message)s")
# a single handler to rule them all
handler = logging.StreamHandler()
handler.setFormatter(formatter)
# root of all the elastic pipes loggers
logger = logging.getLogger("elastic.pipes")
# all the pipes sync their handlers with this
logger.addHandler(handler)
# all the pipes sync their log level with this, unless configured differently
if level is None:
logger.setLevel(default_level)
else:
logger.setLevel(level.upper() if isinstance(level, str) else level)
logger.overridden = True
return logger.level
return _handler