强制 运行 被 ShortCircuitOperator 跳过的任务

Question

我有一个 DAG，它使用 ShortCircuitOperator 来跳过（通常）不必要的下游任务。在一些特殊情况下，我仍然希望 运行 这些下游任务，并且不希望必须修改我的 DAG 来处理所有可能的情况。 Airflow UI 或通过控制台是否有一种简单的方法在下游任务被跳过后强制执行 运行？

Answer 1

在这里回答我自己的问题，您可以通过UI手动清除任务实例的状态，但您必须清除下游任务的状态。我 运行 遇到了问题，因为我想跳过 DAG 的一部分，并试图清除更下游的任务状态，这当然会导致它们立即被设置为再次跳过。如果你真的想以这种方式跳过 DAG 的一部分，你可以这样做，你只需要手动设置你想要的任务上游的依赖关系 运行 成功。