当您在Airflow中运行DAG时,可能会遇到DagRunNotFound错误。这通常是由于Airflow数据库中不存在相应的DagRun或未正确记录DagRun而引起的。
为了解决此问题,您可以尝试运行以下代码:
from airflow.models import DAG, DagRun from datetime import datetime
dag_id = 'YOUR_DAG_ID' exec_date = datetime(2022, 3, 1) dag = DAG(dag_id = dag_id, start_date = exec_date) dag_run = DagRun.find(dag_id = dag_id, execution_date = exec_date) if dag_run is None: dag_run = dag.create_dagrun(execution_date=exec_date, state="running")
在您的代码中使用此代码将检查是否存在DagRun并创建一个新的DagRun。这将解决Airflow DagRunNotFound问题。