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

Question

我们最近从气流1.10.12升级到气流2.1.0，并且在我们的每个包的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

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