Мой дизайн приложения требует, чтобы DAG Airflow, которая выполняется в данный момент, могла быть приостановлена при выполнении, возобновлена, если приостановлена и остановлена. Это отличается от предоставляемых функций приостановки / отмены. Например, если группа обеспечения доступности баз данных имеет 8 компонентов и 3 компонента уже успешно выполнены. Теперь я хочу приостановить выполнение этого DAG. Через некоторое время я хочу возобновить этот приостановленный DAG. После 6 компонентов я понял, что у этого DAG есть большой недостаток, и мне нужно прекратить его выполнение.
Я попытался найти эти три функции в документации CLI , но не смог найти эти функции. Документация по API также не говорит ни о каком API, который может это сделать.
попросил бы ветеранов Airflow предложить это.