Christian Michelsen
07/08/2021, 9:25 AMKevin Kho
Christian Michelsen
07/08/2021, 2:12 PM@task()
def task_a():
logger = prefect.context.get("logger")
logger.debug("TASK A: Returning 3")
<http://logger.info|logger.info>("TASK A: Returning 3")
logger.warning("TASK A: Returning 3")
logger.error("TASK A: Returning 3")
return 3
@task()
def task_b(x):
logger = prefect.context.get("logger")
y = 3 * x + 1
return y
prefect.utilities.logging.prefect_logger.setLevel("INFO")
f_handler = logging.FileHandler("file.log", mode="w")
f_handler.setLevel(logging.DEBUG)
f_format = logging.Formatter("%(asctime)s - %(name)s - %(levelname)s - %(message)s")
f_handler.setFormatter(f_format)
with Flow("logging-example") as flow:
result = task_b(task_a)
task_logger = get_logger()
task_logger.addHandler(f_handler)
task_logger.setLevel(logging.DEBUG)
flow.run()
Christian Michelsen
07/08/2021, 2:14 PMKevin Kho
Kevin Kho