気流DAGが一度に1日に実行されるようにするにはどうすればよいですか？

Question

DAGを一度に1日実行するように設定したいとします。 これをどうすれば実現できますか？

私は "depends on past = True"を試しましたが、各タスクが後で実行されることを確認します。私が欲しいのは、もし私がX日から戻ってきたなら、X日のすべてのタスクがX + 1日のDAGの前に実行されるということです。

Answer 1

このページをチェックアウト：https://airflow.apache.org/scheduler.html#dag-runs
0 0 * * *でschedule_intervalを設定できます。あなたはSTART_DATE数日前に真catchup_by_default =を設定している場合は
、空気の流れは、あなたがアクティブなDAGの実行の数を制御するためにmax_active_runsを使用することができますschedule_interval

Answer 2

に基づいてスケジュールを実行し、その後最初にすべてのあなたの前のタスクを埋め戻します。 これを1つに限定すると、ユースケースを満たす必要があります。

dag = airflow.DAG(
    'customer_staging', 
    schedule_interval="@daily", 
    dagrun_timeout=timedelta(minutes=60), 
    template_searchpath=tmpl_search_path, 
    default_args=args, 
    max_active_runs=1)