可以采取以下方法解决此问题:
DAG_NAME = DAG('dag_name', start_date=datetime(2021, 1, 1, 6, 0),
schedule_interval=timedelta(days=1))
airflow list_dags
task_a >> task_b
airflow logs dag_name
通过采用以上方法,您可以解决 DAG 没有按照开始时间和计划间隔运行的问题。
上一篇:AirflowDAG未按计划执行
下一篇:AirflowDAG未被触发