我如何告诉Prefect,不要在DAG中重新运行所有以前的任务?

发布于 2021-12-03 22:33:03
Targets会带你去你想去的地方。从文档中:
Prefect中的
目标是可模板的位置字符串,用于检查任务结果是否存在。如果您希望任务只将数据写入某个位置一次,或者如果某个数据片段存在,则不重新运行,则这一点非常有用。如果结果存在于该位置,则任务运行将进入缓存状态。
在你的任务装饰器中,只需添加一个目标,如下所示:
@task(result=LocalResult(), target="{task_name}-{today}")https://stackoverflow.com/questions/66671409
复制相似问题