气流DAG成功回调

Question

有没有一种优雅的方法来为DAG成功事件定义回调？我真的不想设置一个任务，它将使用on_sucess_callback在所有其他任务的上游。

谢谢！

Answer 1

因此，如果我理解正确的话，DAG 的最后一步是，如果成功，则回调到其他系统。因此，我鼓励您完全按照这种方式对 DAG 进行建模。

您为什么要尝试从 DAG 逻辑中隐藏该部分？这正是上游/下游建模的目的。为了图形的美观而隐藏部分 DAG 逻辑对我来说听起来是一个糟糕的权衡。

我不鼓励您将回调任务设置为所有任务的下游，它应该仅是DAG 中最终任务的下游。