在创建表之前，Airflow 在“airflow resetdb”时填充 DagBag 时引发错误

【问题标题】：Airflow throw an error on filling up the DagBag while "airflow resetdb", before tables created在创建表之前，Airflow 在“airflow resetdb”时填充 DagBag 时引发错误
【发布时间】：2019-04-25 08:00:51
【问题描述】：

我正在使用 Airflow 动态构建 dag。 dag builder 使用“变量”来获取和设置值。

当我运行“airflow resetdb”时，Airflow 抛出错误：“(psycopg2.ProgrammingError) 关系“变量”不存在”。

我看到 Airflow 在“airflow resetdb”期间和创建表之前填充了 DagBag。

为什么气流运行“Filling up the DagBag”，而“airflow resetdb”？

有什么办法可以解决吗？

【问题讨论】：

标签： airflow

【解决方案1】：

运行airflow upgradedb。这将为您创建所有缺少的表。

【讨论】：

表存在，问题是当我运行“airflow resetdb”时，它首先删除表然后重新创建它们。但是在重新创建表格之前，它会填满 DagBag（不知道为什么）。
虽然回答这个问题已经很晚了，但让我在这里添加一个可能对其他人有帮助的步骤。首先，我们需要删除 dags 文件夹中的所有文件，然后运行airflow resetdb 命令。该命令将运行而不会出现任何错误。