阅读有关的文档后基于文件目标的输出缓存 https://docs.prefect.io/core/concepts/persistence.html#output-caching-based-on-a-file-target,我认为这个工作流程应该是输出缓存的一个示例:
from time import sleep
from prefect import Flow, task
from prefect.engine.results import LocalResult
@task(target="func_task_target.txt", checkpoint=True,
result=LocalResult(dir="~/.prefect"))
def func_task():
sleep(5)
return 99
with Flow("Test-cache") as flow:
func_task()
if __name__ == '__main__':
flow.run()
我希望func_task
运行一次,进行缓存,然后在下次运行流程时使用缓存的值。然而,似乎func_task
每次运行。
我哪里错了?或者我误解了文档?
尝试设置环境变量PREFECT__FLOWS__CHECKPOINTING
to True
import os
os.environ["PREFECT__FLOWS__CHECKPOINTING"] = "true"
您还可以更改结果目录
os.environ["PREFECT__HOME_DIR"] = "path to dir"
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)