Когда я запускаю dag с параметром Variable, возникает исключение - PullRequest
0 голосов
/ 20 декабря 2018

Я использую apache-airflow == 1.10.0

Я получаю ошибки, которые выглядят следующим образом:

sqlalchemy.exc.ProgrammingError: (psycopg2.ProgrammingError) relation "variable" does not exist
LINE 2: FROM variable

Когда я объявляю такие задачи, как:

 from airflow.models import Variable
 dag = DAG('dag')
 PythonOperator('task_id', ratio=Variable.get('ratio'), dag=dag)

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

1 Ответ

0 голосов
/ 21 декабря 2018

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

...