Airflow выдает ошибку при заполнении DagBag при «airflow resetdb», до создания таблиц - PullRequest
0 голосов
/ 25 апреля 2019

Я использую Airflow для динамического создания дагов. Конструктор dag использует «переменную» для получения и установки значений.

Когда я запускаю «airflow resetdb», Airflow выдает ошибку: «(psycopg2.ProgrammingError) отношение« переменная »не существует».

Я вижу, что Airflow заполняет DagBag, пока "airflow resetdb" и до создания таблиц.

Почему воздушный поток работает "Заполнение DagBag", а "airflow resetdb"?

Есть ли способ ее решить?

1 Ответ

0 голосов
/ 25 апреля 2019

Пробег airflow upgradedb. Это создаст все недостающие таблицы для вас.

...