В моем Airflow есть DAG, который полностью отказывался каждый день до определенного дня. Все первые задачи (dag_start) красные, а последующие оранжевые.
Теперь я решил первую задачу и восстановил данные за пределами воздушного потока, и я хочу отметить их как успешные.
Когда я делаю это через GUI, используя «Прошлое» или «Успех», появляется пустой список. Когда я делаю это через интерфейс командной строки (airflow my_dag dag_start 2019-01-01 -m -i), он работает без ошибок, но в GUI это не отражается. Мы запускаем Airflow по местному времени (не UT C), и я чувствую, что это связано с этим.
airflow my_dag dag_start 2019-01-01 -m -i
Я также запускал его без -m, но даже тогда он не отражался в GUI, однако в нем говорилось: Запуск% s на хосте% s myhost
Я понятия не имею, что еще я могу сделать, кроме как отмечать более 100 задач по одной в GUI.
Когда я нажимаю один такт, чтобы отметить его как успешный, я получаю следующее:
Вот список экземпляров задачи, которые вы собираетесь отметить как успешные: <TaskInstance: mydag.dag_start 2019-12-02 12:00:00+00:00 [failed]>
Когда я щелкаю от определенной даты до прошлого, появляется пустой список. Когда я делаю это от даты начала до будущего, я получаю взрыв Airflow, заканчивающийся этим сообщением об ошибке:
File mylib/python3.6/site-packages/pendulum/tz/timezone_info.py", line 99, in fromutc
tzinfo = self._tz._tzinfos[self._tz._transitions[idx]._tzinfo_index]
IndexError: list index out of range
Мы запускаем Airflow 1.10 с localexecuter
Это ошибка воздушного потока или я что то не так делаю? Есть ли рабочий обходной путь или я должен попросить свою 7-летнюю дочь покрасить все коробки в зеленый цвет? : -)