Запуск DAG не начнется после создания с использованием REST API

Question

• Я использую Python для запуска DAG, используя REST API Airflow (v1.10.1).
• Кажется, что прогоны DAG созданы правильно, потому что я вижу их в графическом интерфейсе как «запущенные»
• дата выполнения правильно установлена ​​на то, что я передаю. Однако все узлы DAGпросто оставайтесь в состоянии «нет статуса» и никогда не запускайтесь.
• Может быть, есть другой элемент конфигурации, который мне нужно передать?В настоящее время я передаю только дату исполнения следующим образом:

parameters = {'execution_date': '2019-02-06'}
raw_response = requests.post(url, headers=headers, json=parameters)

Спасибо за любую помощь!

Answer 1

Убедитесь, что ваш планировщик Airflow работает должным образом, поскольку одно из его заданий - запускать экземпляры задач.