如何运行一个气流任务及其所有依赖项?

itz*_*cky 10 airflow python-3.6 airflow-scheduler

我怀疑

airflow run dag_id task_id execution_date

会运行所有上游任务,但事实并非如此.当它看到并非所有依赖任务都运行时,它将失败.如何运行特定任务及其所有依赖项?我猜这是不可能的,因为气流设计的决定,但有没有办法解决这个问题?

Pri*_*hta 6

您可以通过使用-i / -I / -A标志以及run命令来独立运行任务。

但是,是气流的设计不允许运行特定的任务和它的依赖性。

您可以通过从DAG去除不相关的任务,用于测试目的回填达格

  • 那么,实现目标的最佳替代方法是什么(从DAG运行任务及其依赖项)? (3认同)