Airflow: Как выполнить задачу, которая сейчас не включена в DAG? - PullRequest
0 голосов
/ 30 октября 2019

У меня есть эта проблема. Я изменил рабочий процесс DAG, чтобы заменить задачу другим. Но кажется, что замененная задача все еще отражает, но уже не является частью рабочего процесса (см. Изображение). Мой вопрос: как выполнить эту задачу?

enter image description here

Любая помощь очень ценится. Спасибо!

1 Ответ

1 голос
/ 30 октября 2019

Я думаю, что вам лучше всего выключить DAG, перезапустить планировщик (или просто запустить его с airflow scheduler) и wait . Обычно изменения в группах обеспечения доступности баз данных регистрируются только через некоторое время, когда работает планировщик.

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

После того, как некоторые циклы планировщика пройдены и после обновления вы видите только новую конфигурацию, вы можете безопасно включить DAG снова.

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