如何在 AirFlow 中不执行其他任务的情况下正常退出 DAG
How to exit DAG as normal without other tasks execution in AirFlow
有没有办法在不执行后续任务的情况下正常退出Dag？
例如，我做了类似“taskA >> taskB >> taskC”这样的后续任务，如果在taskA中满足某些条件，我想终止它的DAG作为正常结束而不执行后续任务。
是的，试试ShortCircuitOperator
ShortCircuitOperator 仅在满足条件时才允许工作流继续。否则，将跳过工作流“short-circuits”和下游任务。
为了判断下面的任务是否需要执行，用ShortCircuitOperator把条件传给python_callable。
有没有办法在不执行后续任务的情况下正常退出Dag？ 例如，我做了类似“taskA >> taskB >> taskC”这样的后续任务，如果在taskA中满足某些条件，我想终止它的DAG作为正常结束而不执行后续任务。
是的，试试ShortCircuitOperator
ShortCircuitOperator 仅在满足条件时才允许工作流继续。否则，将跳过工作流“short-circuits”和下游任务。
为了判断下面的任务是否需要执行，用ShortCircuitOperator把条件传给python_callable。