当我用可变参数初始化一个 dag 时，它会引发一个异常

Question

我正在使用 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)

因为我还没有变量表。我收到的错误不会影响任何事情，但是我该如何防止这种情况发生？

Answer 1

对于气流<2.0，运行airflow upgradedb. 对于 Airflow >= 2.0，运行airflow db upgrade. 它将创建所有缺失的表。