Как выполнить задачу, если предыдущий не удается в воздушном потоке Apache ⇐ Python

[Anonymous]

Мне нужно сделать следующее: < /p>

Проверьте, не работает ли сервер, если да, то я проверяю, если кластер Spark на этом сервере не работает, я стараюсь запустить его, я уже встал, я буду двигаться вперед, чтобы запустить задание по исчевнику. Если это не удастся, я бы запустил задачу «Start Spark Cluster». Кроме того, мне нужно было проверить предыдущий на случай, если он будет успешным, поэтому он будет перемещаться до задачи задания Spark и пропустить задачу «Start Spark Cluster». Я попытался использовать Trigger_rule и оператор филиала, но пока ничего не получил. Может быть, потому что в Интернете слишком мало примеров кода. < /P>

Спасибо < /p>

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