如何手动运行以前从未运行过的 Airflow 任务

Question

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

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

现有任务的菜单：

将鼠标悬停在新任务上：

Answer 1

如果任务有上游或下游任务，您可以使用“标记成功”旁边的“上游”或“下游”按钮“标记成功”。之后，您可以单击并清除任务。或者您可以使用 CLI 在 https://stackoverflow.com/a/58607672/16260639

的帮助下完成此操作

Answer 2

但是如果您有多个任务都位于上游任务的下游，

清除上游任务后，所有下游任务都会被触发。

如何只触发其中1个下游任务？

气流图 - 其中 1 步之前从未运行过