Группа обеспечения доступности баз данных Airflow повторит попытку, если какая-либо из задач Airflow завершится неудачно ⇐ Python

[Anonymous]

Хотелось бы задать вопрос по Airflow, в настоящее время, когда мы устанавливаем аргументы DAG по умолчанию на повторную попытку 5 раз,
в случае сбоя

Код: Выделить всё

   default_args = {
'owner': 'testing',
'retries': 5,
'retry_delay': timedelta(minutes=1)
}

Итак, теперь происходит следующее: если какие-либо задачи в группе DAG завершатся неудачно, она повторит попытку выполнения задач. Хотелось бы знать, есть ли какой-либо способ установить, не удается ли какой-либо из задач вместо этого перезапустить всю группу обеспечения доступности баз данных?
Проверить группу обеспечения доступности баз данных
task1 - -> задача2 -> задача3 -> задача4
так, например, если в задаче 3 произошел сбой, я бы хотел, чтобы она снова началась с задачи 1. это возможно??
Спасибо

Подробнее здесь: https://stackoverflow.com/questions/791 ... asks-fails