如果以前从未运行过 Airflow 任务,如何手动运行它

Rob*_*wen 2 python airflow

我多次遇到这个问题,但找不到解决方案。我在 Airflow 中有一个每天运行的 DAG,效果很好。有时我会向此 DAG 添加新任务,然后将其包含在下一次计划的 DAG 运行期间,这也很棒。

然而,有时我想立即运行新任务,因为我想立即使用结果。这似乎只能通过运行整个 DAG 来实现,但我不想这样做。如果任务已经运行,您可以单击它,清除其状态,手动运行它,并执行各种操作。但是,如果这是一个以前从未运行过的新任务,则您不能执行这些操作,因为它在悬停时会显示“停止”标志(并且显示“DAG 尚未运行”),并且您不能点击它。其中一些是有道理的(您无法重置状态,因为它尚未运行,因此它没有状态)。但是,我仍然希望能够手动运行它,就像处理现有任务一样。感觉这应该是可能的,但我不知道如何实现。

现有任务的菜单:

现有任务的菜单

将鼠标悬停在新任务上:

将鼠标悬停在新任务上

小智 5

如果任务有上游或下游任务,您可以使用“标记成功”旁边的“上游”或“下游”按钮“标记成功”。之后,您可以单击并清除任务。或者您可以在/sf/answers/4102537071/的帮助下使用 CLI 来完成此操作