João Amorim
06/30/2021, 2:19 PMKevin Kho
class PropagateHandler(logging.Handler):
def emit(self, record):
logging.getLogger(record.name).handle(record)
logger.add(PropagateHandler(), format="{message}")
where logger is the Prefect logger. You would be adding the Handler to the Prefect logger.Kevin Kho
InterceptHandler
like this to add them to your logs before they go to the sink. Try adding the logger to the Prefect logger like:
from prefect.utilities.logging import get_logger
prefect_logger = get_logger()
prefect_logger.addHandler(InterceptHandler)
João Amorim
06/30/2021, 3:15 PM