当尝试通过airflow trigger_dag test_dag运行dag时,我得到了错误:airflow.exceptions.DagNotFound: Dag id test_task not found运行airflow list_dags时,DAG正确列出。我还进行了检查,以确保将$AIRFLOW_HOME目录正确设置为dag所在的位置。我能让它工作的唯
我是Airflow.I的新手,我想读取用户传递的触发器DAG配置,并将其存储为变量,该变量可以作为作业参数传递给实际代码。想要访问在触发DAG时传递的所有参数。def get_execution_date(**kwargs):
if ({{kwargs["dag_run"].conf["execution_date"]}}) is not None:e