Сбой потока воздуха ... но все задачи выполнены

Question

Я очень смущен чем-то в нашем интерфейсе. В древовидном представлении (и графическом представлении) указывается, что даг не выполнен. Тем не менее, все его задачи-члены, кажется, успешно. Вы можете видеть это здесь ниже (третий от конца):

Кто-нибудь знает, как это возможно, что это значит или как его можно исследовать?

Answer 1

Я испытал то же самое. Все задачи выполнены успешно, но DAG не удается. Не нашел ничего ни в одном журнале.

В моем случае это был параметр dagrun_timeout группы обеспечения доступности баз данных, который был слишком низким для моих задач, которые выполнялись более 30 минут:

dag = DAG(...,
          dagrun_timeout=timedelta(minutes=30),
          ...)

Я в версии 1.10.1 Airflow.