После очистки журналов Dag находится в рабочем состоянии, но задача не запланирована / не выполняется

У меня есть воздушный поток (v1.10.4), работающий в кластере Kubernetes с использованием Celery Executor. Мы используем RDS Postgres в качестве базы данных внешних метаданных.

Постановка проблемы: все даги планируются и запускаются вовремя, но проблема возникает, когда мы очищаем любой журнал (старый прогон) для повторного запуска конвейера. Airflow переводит этот даг в рабочее состояние, но ни одна из задач не выполняется. Мы также видели, когда мы повторно отмечали эти очищенные журналы как успешные, Airflow планирует следующий запуск, но ни одна из задач не выполняется (ни одна из задач не переходит в очередь или состояние выполнения).

Рассматриваемый тег имеет зависимые_on_past=True и catchup=True.

Может кто знает, что здесь не так?

см. этот снимок экрана

0 ответов

Другие вопросы по тегам