我正在以一种复杂的方式运行一系列相互依赖的任务。我想将这些依赖关系描述为DAG (有向无环图),并在需要时执行该图。我一直在关注airflow,并写了一个虚拟脚本: from datetime import datetime
from airflow.operators.python(dag_id="my_id", schedule_interval=None, start_date=datetime
当尝试通过airflow trigger_dag test_dag运行dag时,我得到了错误:airflow.exceptions.DagNotFound: Dag id test_task not found运行airflow list_dags时,DAG正确列出。我还进行了检查,以确保将$AIRFLOW_HOME目录正确设置为dag所在的位置。我能让它工作的唯一方法就是