Есть ли какая-либо документация XML Android? [закрытый]

Прежде всего: это отличный вопрос, мне интересно, почему он до сих пор не обсуждался широко

Я могу вспомнить два возможных подхода

[ 1132]

---

Подход с использованием отдельных групп DAG верхнего уровня

Учитывая

• Скажем, у вас есть задачи A & amp; B
• A является восходящим по отношению к B
• Вы хотите возобновить выполнение (повторить попытку) с A, если B не удается

(Возможно) Идея : Если вы чувствуете себя предприимчивым

• Поставьте задачи A & amp; B в отдельных верхних уровнях DAG с, скажем, DAG-A & amp; DAG-B
• В конце DAG-A запустите DAG-B, используя TriggerDagRunOperator
  • По всей вероятности, вам также придется использовать ExternalTaskSensor после TriggerDagRunOperator [ 1155]
• В DAG-B поставьте BranchPythonOperator после Задачи-B с trigger_rule=all_done
• Этот BranchPythonOperator должен перейти в другой TriggerDagRunOperator, который затем вызывает DAG-A (снова!)

Полезные ссылки

• Объединение операторов вместе
• ] Соединение групп DAG верхнего уровня вместе

EDIT-1

Вот гораздо более простой способ, который может обеспечить подобное поведение

Как можно перезапустить задачу вверх по течению, если задача потока ниже не выполняется в Airflow (с использованием вспомогательных пакетов)