在Airflow 2.0版本中,出现"调度器无法在 serialized_dag 表中找到序列化的 DAG"的错误是因为Airflow 2.0使用了新的序列化DAG的方法。以下是解决此错误的代码示例:
default_args
字典,该字典用于指定DAG的默认参数。default_args = {
'owner': 'airflow',
'start_date': datetime(2022, 1, 1)
}
dag = DAG(
dag_id='my_dag',
default_args=default_args,
schedule_interval='0 0 * * *'
)
from airflow import DAG
from datetime import datetime
__main__
块,并在其中实例化DAG。if __name__ == "__main__":
dag.cli()
通过以上步骤,你应该能够解决"调度器无法在 serialized_dag 表中找到序列化的 DAG"的错误。