我如何告诉 Prefect 不要重新运行 DAG 中的所有先前任务？
问问题
64 次
1 回答
0
目标会把你带到你想去的地方。从文档：
Prefect 中的目标是可模板化的位置字符串，用于检查任务结果是否存在。这在您可能希望任务仅将数据写入某个位置一次或仅在存在某些数据时不重新运行的情况下很有用。如果该位置存在结果，则任务运行将进入缓存状态。
在您的任务装饰器中，只需添加一个目标，如下所示：
@task(result=LocalResult(), target="{task_name}-{today}")
于 2021-12-03T22:33:03.300 回答