气流回填新任务添加到 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-01 开始的日期的 DAG 运行。如果不是这种情况，请确保 DAG 的开始日期为 2017 年 10 月 1 日或更早，并且已启用追赶。