#python-3.x #airflow #airflow-scheduler
Вопрос:
У меня есть DAG воздушного потока, который планируется запускать раз в месяц. DAG прекрасно работал до 01-08-2021. Следующее расписание было на 01-09-2021. DAG и задача находились в состоянии УСПЕХА, но DAG фактически не выполнялась. Я не мог видеть даты начала и окончания экземпляра задачи. Журналов тоже нет. Любая помощь будет признательна. Спасибо!
Версия воздушного потока : 1.10.6
Экземпляры задач : Все находятся в состоянии УСПЕШНОГО выполнения 
Детали DAG :
| Клавиша | ценность |
|---|---|
| schedule_interval | 0 6 1 * * |
| max_active_runs | 0 / 16 |
| совпадение | 16 |
| default_args | {‘provide_context’: True, ‘depends_on_past’: False, ‘дата начала’: <Маятник [2021-05-01T00:00:00 00:00]>, ‘повторные попытки»: 1, «catchup_by_default»: Ложь, «retry_delay»: дата и время. timedelta(0, 300)} |
| количество задач | 1 |
| идентификаторы задач | [‘GENERATE_INVOICE’] |
| путь к файлу | invoicing.py |
| владелец | воздушный поток |
Комментарии:
1. Может быть, кто-то просто отметил это как Успех? (проверьте журналы) в любом случае вы можете очистить соответствующие задачи, чтобы они выполнялись
2. В этой группе DAG выполняется только одна задача. Я как-то попытался получить журнал с сервера Airflow. [2021-09-02 05:25:06,827] {taskinstance.py:624} ИНФОРМАЦИЯ — Зависимости не выполнены для GENERATE_INVOICE 2021-08-01T06:00:00 00:00 [успех]>, зависимость «Состояние экземпляра задачи» НЕ УДАЛАСЬ: Задача находится в состоянии «успех», которое не является допустимым состоянием для выполнения. Для запуска задача должна быть очищена. [2021-09-02 05:25:06,829] {logging_mixin.py:112} ИНФОРМАЦИЯ — [2021-09-02 05:25:06,829] {local_task_job.py:91} ИНФОРМАЦИЯ — Задача не может быть запущена