Felix Schran
01/25/2021, 1:59 PMDylan
Zanie
addHandler
.
import os
from logging import FileHandler
import prefect
from prefect.environments.storage import Local
from prefect import task, Flow
LOG_PATH = os.path.expanduser("~/flow-logs.txt")
def get_logger():
logger = prefect.context.get("logger")
logger.addHandler(FileHandler(LOG_PATH))
return logger
@task()
def report_start_day():
logger = get_logger()
<http://logger.info|logger.info>(prefect.context.today)
<http://logger.info|logger.info>(prefect.context.flow_run_id)
with Flow("flow-that-logs", storage=Local()) as flow:
report_start_day()
flow.register(project_name="default")
Felix Schran
01/25/2021, 5:38 PMZanie