我想在Airflow中创建一个条件任务，如下面的架构中所述。预期的情况如下:任务1执行如果任务1成功，则执行任务2aElse如果任务1失败，则执行任务2b最终执行任务3以上所有任务都是SSHExecuteOperator。我猜我应该使用ShortCircuitOperator和/或XCom来管理条件，但我不清楚如何实现它。你能描述一下解决方案吗？ 最佳答案 Airflow有BranchPythonOperator可以用来更直接地表达分支依赖。docs描述它的用途:TheBranchPythonOperatorismuchliketh

我想在Airflow中创建一个条件任务，如下面的架构中所述。预期的情况如下:任务1执行如果任务1成功，则执行任务2aElse如果任务1失败，则执行任务2b最终执行任务3以上所有任务都是SSHExecuteOperator。我猜我应该使用ShortCircuitOperator和/或XCom来管理条件，但我不清楚如何实现它。你能描述一下解决方案吗？ 最佳答案 Airflow有BranchPythonOperator可以用来更直接地表达分支依赖。docs描述它的用途:TheBranchPythonOperatorismuchliketh