相关疑难解决方法(0)

我想在Airflow中创建一个条件任务,如下面的架构中所述.预期的情况如下:

• 任务1执行
• 如果任务1成功,则执行任务2a
• 否则,如果任务1失败,则执行任务2b
• 最后执行任务3

上面的所有任务都是SSHExecuteOperator.我猜我应该使用ShortCircuitOperator和/或XCom来管理这个条件,但我不知道如何实现它.你能描述一下解决方案吗？