仅从 Apache Airflow 中的 DAG 运行特定任务

Question

Apache Airflow 中是否有一种方法可以临时从 DAG 运行单个任务，控制它是仅运行其上游任务还是下游任务，而不运行整个 DAG？,

类似于 dbt CLI 允许选择特定模型来运行

dbt run --select +model_name+

Answer 1

如果您希望运行一个任务以及所有下游任务而不是整个 DAG，您可以手动清除该任务。

例如，task1>>task2>>task3，在airflow UI中，只需单击“task2”，然后单击弹出菜单中的“清除”，就会运行task2和task3。

如果您希望运行一个任务和所有任务而不是整个 DAG，我认为气流不支持这种行为，因为您可以想象气流将任务作为图形运行，可以从“根”开始，但不可能以“叶子”结束。 在这种情况下，您可以在代码级别注释无用的任务。