2017-10-31 5 views
0

DAGに新しいタスクを追加しました。バックアップする必要があります。現時点では、airflow backfillを実行すると、すべてのタスク(新しいものと古いもの)が実行され、既に成功している古いタスクは無視したいと考えています。気流 - バックフィルで成功したタスクを無視するにはどうすればよいですか?

バックフィルで成功状態のタスクをスキップする方法はありますか?

答えて

1

エアフローバージョン1.8.1では、成功したタスクはバックフィルによってスケジュールされません。AIRFLOW-1124を参照してください。

-t TASK_REGEX, --task_regex TASK_REGEX 
        The regex to filter specific task_ids to backfill 
        (optional) 

あなたの新しいタスクが成功していない可能性があります任意の古いものに依存しても、ケースであなたを助けるかもしれない依存関係フラグを無視する:あなたはまた、あなたが埋め戻しに実行したいタスクを指定することができ

注意。

-i, --ignore_dependencies 
        Skip upstream tasks, run only the tasks matching the 
        regexp. Only works in conjunction with task_regex 
関連する問題