При использовании TriggerDagRunOperator от Airflow целевой прогон DAG помечается как «успешный» без выполнения дочерних задач. - PullRequest
0 голосов
/ 17 апреля 2019

Используя TriggerDagRunOperator, я могу запустить прогон DAG. После непродолжительного «запуска» запущенная группа доступности базы данных помечается как успешная, , но дочерние задачи не выполняются.

Кроме того, я не могу попасть в контекстное меню, в котором я могу вручную запустить / очистить / и т.д. экземпляр задачи. То есть ничего не происходит, когда я нажимаю на запущенные экземпляры задач группы обеспечения доступности баз данных в графическом / древовидном представлении.

Некоторые вещи стоит отметить:

  • Я запустил каждую группу DAG "новой", например, я очистил все записи и удалил DAG все вместе.

  • Исходная дата начала DAG совпадает как start_date сработавшего DAG и сработавшего DAG для параметра schedule_interval установлено значение None.

  • Я не использую вызываемый Python для условного запуска DAG.
    Задача TriggerDagRunOperator будет выполнена, если все восходящие задачи завершены.

Я исследовал эту проблему, но, похоже, не могу найти хорошую информацию. Кто-нибудь еще сталкивался с подобной проблемой, и если да, можете ли вы порекомендуйте некоторые дополнительные меры по устранению неполадок, которые я могу предпринять, чтобы заставить это работать правильно?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...