如何处理 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 后，错误消失了。