У нас есть 3 узла GKE-композитора и 3 рабочих модуля, равномерно распределенных по всем 3 узлам. Мне нужно знать, как проверить, какая группа DAG или задача в данный момент выполняется в каком модуле. Я попытался запустить airflow list_dag, но, как...

Я использую обдув с сельдереем. В качестве примера у меня есть даг с 3-мя задачами. задача1 ›› задача2 ›› задача3 Когда мои рабочие узлы = 1, я вижу, что задачи выполняются нормально и в правильной последовательности. Однако, когда я увеличиваю...

Пример использования: в DAG определена задача Rest API (с использованием RestOperator), которая обращается к API приложения и запускает выполнение процесса / задачи, которая выполняет некоторую бизнес-функцию. Статус выполнения отслеживается с...

Я запускаю Airflow через докер через этот образ. apache/airflow:2.1.0 Пожалуйста, обратитесь к этой теме для начальной ошибка, с которой я столкнулся. В настоящее время я могу запускать свои предыдущие существующие DAG. Однако, когда я...