AirFlow - отключить dag после X неудачных попыток - PullRequest
2 голосов
/ 20 марта 2019

Я прочитал ссылку на API и не смог найти на ней ничего, это возможно?

1 Ответ

1 голос
/ 21 марта 2019

В настоящее время нет такой функции, которая бы делала это из коробки, но вы можете написать собственный код в DAG, чтобы обойти это. Например, используйте PythonOperator (вы можете использовать оператор MySQL, если ваша база метаданных - mysql), чтобы получить статус последних X выполнений для dag. используйте BranchPythonOperator, чтобы узнать, больше ли число, чем X, и затем использовать BashOperator для запуска airflow pause dag cli.

Вы также можете просто сделать это двухэтапной задачей, добавив логику PythonOperator в BranchPythonOperator. Это просто идея, вы можете использовать другую логику.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...