airflow - 气流回填新任务添加到 dag

Question

假设今天是 2017-10-20。我有一个现有的 dag，直到今天仍然成功。我需要添加一个 start_date 为 2017-10-01 的任务。如何使调度程序从 2017-10-01 到 2017-10-20 自动触发任务？

Answer 1

您可以使用回填命令行工具。

airflow backfill your_dag_id -s 2017-10-01 -e 2017-10-20 -t task_name_regex

这是假设从 2017 年 10 月 1 日开始的日期已经有一个 DAG 运行。如果不是这种情况，请确保 DAG 的开始日期为 2017 年 10 月 1 日或更早，并且启用了追赶。

Answer 2

如果您不介意再次执行整个 DAG，可以将其从 Web UI 中删除，它会再次以 status 出现Off。如果您再次启用它，它将从头开始运行，包括新任务。