Проблема с Airflow версии 1.10.1

Question

Недавно я обновил версию воздушного потока до 1.10.1. Я включил некоторые из включенных ярлыков, которые ранее были отмечены как ВЫКЛ. Я всегда использую start_date для dag как сегодняшнюю дату. После включения дагов это принесло ниже вопроса.

Планировщик, однако, запускает эти группы DAG, но не выбирает связанные задачи. В экземпляре задачи подробно показано "Дата выполнения 2018-12-04T13:00:00+00:00, но это до даты начала задачи 2019-02-04T00:00:00+00:00". Он запускается только после запуска вручную.

Есть ли другой способ (кроме исправления start_date для DAG), эту проблему можно исправить. то есть; используя какой-либо конфиг или любой другой вариант, где я могу обойти вышеупомянутую проверку даты выполнения и даты начала задачи.

Моя главная цель - запустить старое расписание Дага без ручного вмешательства.

Answer 1

Вы не должны использовать динамическую дату начала, особенно сегодняшнюю дату или datetime.now(), Прочитайте официальные документы https://airflow.readthedocs.io/en/stable/faq.html для получения более подробной информации.

Я знаю, что вы спрашивали о предложении помимо даты начала, но ваша дата начала обязательно должна быть раньше даты выполнения задачи. Следовательно, я настоятельно рекомендую изменить ваш start_date что-то вроде datetime(2018, 1, 1),