气流2.1.0 - serialized_dag表中找不到DAG 'XXXXXXXX‘

Question

我们最近从风流1.10.12升级到了气流2.1.0，并且在每个dags的UI中都会出现这样的问题错误。

我们已将版本从1.10.12升级到1.10.15，并取得了成功。然后，我们从1.10.15升级到2.1.0，并面临着这个问题。

File "/home/airflow/.local/lib/python3.6/site-packages/airflow/models/dagbag.py", line 249, in _add_dag_from_db
    raise SerializedDagNotFound(f"DAG '{dag_id}' not found in serialized_dag table")
airflow.exceptions.SerializedDagNotFound: DAG 'XXXXXXXX' not found in serialized_dag table

Answer 1

在运行了两个调度程序实例后，获得了此错误。由于只保留了调度程序的一个实例，问题得到了解决。