Как создать условную задачу в Airflow ⇐ Python

[Anonymous]

Я хотел бы создать условную задачу в Airflow, как описано в схеме ниже. Ожидаемый сценарий следующий:

• Задача 1 выполняется
• Если задача 1 выполнена успешно, выполнить Задача 2a
• Иначе Если задача 1 не удалась, выполните задачу 2b
• Наконец выполните задачу 3

Все вышеперечисленные задачи выполняются с помощью SSHExecuteOperator.
Я предполагаю, что мне следует использовать ShortCircuitOperator и/или XCom для управления условие, но я не понимаю, как это реализовать. Не могли бы вы описать решение?

Подробнее здесь: https://stackoverflow.com/questions/436 ... in-airflow