Я установил задачу BranchPythonOperator в Apache Поток воздуха, который может вызываться python. Вызываемый python возвращает состояние «вверх» или «вниз». На основании полученного результата принимается дополнительное решение. Как вы берете результат предыдущей задачи и отправляете его в последующие задачи. Я думал о XCOM, но не уверен.