重新运行 DAG 按顺序运行
Rerun DAG Runs in order
假设我每天安排一个 DAG 运行,今天是星期天。有没有办法告诉 Airflow 按顺序重新运行 从星期一到今天的所有 DAG 运行?
您可能需要为 dag 使用参数:depends_on_past
和 wait_for_downstream
,这将强制任务等待之前的任务。
https://airflow.apache.org/docs/stable/_api/airflow/models/index.html#airflow.models.BaseOperator
假设我每天安排一个 DAG 运行,今天是星期天。有没有办法告诉 Airflow 按顺序重新运行 从星期一到今天的所有 DAG 运行?
您可能需要为 dag 使用参数:depends_on_past
和 wait_for_downstream
,这将强制任务等待之前的任务。
https://airflow.apache.org/docs/stable/_api/airflow/models/index.html#airflow.models.BaseOperator