python - 如何处理 Airflow 中的 'Default_args' 错误？

Question

我收到此错误:

Broken DAG: [/usr/local/airflow/dags/reg_controller_new.py] type object 'DAG' has no attribute 'default_args'

我在谷歌上没有找到任何足够的信息可以帮助我解决这个问题。

Answer 1

就我而言，这是来自另一个 StackOverflow 问题的错误复制/粘贴。我复制了以下运算符

t3 = PythonOperator(
    task_id=t3_id,
    python_callable=pull_function,
    provide_context=True,
    dag=DAG
)

并且没有注意到它悲伤的是DAG(类)而不是dag(已经设置了default_args的实例化变量)。将 DAG 更改为 dag 后，错误消失。