Christian Eik
06/10/2021, 2:29 PM@task(state_handlers=[post_task_fail])
def add_headers(headers: list, data: tuple) -> List:
logger = prefect.context.get("logger")
<http://logger.info|logger.info>(prefect.config.flows.checkpointing)
<http://logger.info|logger.info>(prefect.config.tasks.checkpointing)
return headers + list(data)
*edit: but -> and config values ...Kevin Kho
PREFECT__FLOWS__CHECKPOINTING=false
environment variable? Did you set it on the agent?Christian Eik
06/10/2021, 2:50 PM[tasks]
checkpointing = "false"
[flows]
checkpointing = "false"
Christian Eik
06/10/2021, 2:51 PMChristian Eik
06/10/2021, 2:53 PMKevin Kho
Kevin Kho
Christian Eik
06/10/2021, 3:26 PMKevin Kho
@task(checkpoint-False)
Christian Eik
06/10/2021, 3:32 PMChristian Eik
06/10/2021, 3:33 PMKevin Kho
Kevin Kho
Christian Eik
06/10/2021, 3:46 PMChristian Eik
06/10/2021, 3:46 PMChristian Eik
06/10/2021, 3:47 PMKevin Kho
Kevin Kho
Christian Eik
06/10/2021, 3:48 PMChristian Eik
06/10/2021, 3:48 PM