在 Airflow CLI 中测试 DAG 时出现 DagNotFound 错误

Question

I\xe2\x80\x99m 收到错误：airflow.exceptions.DagNotFound: Dag id test_task not found in DagModel尝试通过airflow trigger_dag test_dag.

\n\n

运行时 DAG 已正确列出airflow list_dags。我还检查过以确保 $AIRFLOW_HOME 目录正确设置为 dag 所在的位置。我可以让它工作的唯一方法是运行特定任务，例如airflow test test_dag test_task. 运行python dags/test_dag.py显示没有错误。

\n\n

导入后 dag 文件本身的代码：

\n\n

default_args = {\n    'owner': 'airflow',\n    'depends_on_past': False,\n    'start_date': datetime(2015, 6, 1),\n    'email': ['my@email.com'],\n    'email_on_failure': False,\n    'email_on_retry': False,\n    'retries': 1,\n    'retry_delay': timedelta(minutes=5),\n}\n\ndag = DAG(\n  dag_id='test_dag'\n  default_args=default_args, \n  schedule_interval=timedelta(days=1)\n)\n\n

\n

Answer 1

您需要使用dag_id参数：

dag = DAG(
    dag_id='test_dag', 
    default_args=default_args, 
    schedule_interval=timedelta(days=1)
)