dag = DAG(
dag_id='error_config',
default_args=default_args,
schedule_interval= '*/10 * * * *')
我DAG的ARG游戏这样的,但是当我点击了网页上的“运行”按钮,此DAG只有正常运行,但未来schedule_interval后不能自动运行为什么我的气流不按schedule_interval运行?
dag = DAG(
dag_id='error_config',
default_args=default_args,
schedule_interval= '*/10 * * * *')
我DAG的ARG游戏这样的,但是当我点击了网页上的“运行”按钮,此DAG只有正常运行,但未来schedule_interval后不能自动运行为什么我的气流不按schedule_interval运行?
我建议检查气流的哪个版本您正在运行,版本为1.8+以上的版本使用start_date。细节可以在这里找到:https://github.com/apache/incubator-airflow/blob/master/UPDATING.md#less-forgiving-scheduler-on-dynamic-start_date
所以datetime.now()不被认为是最佳做法,并可能导致DAGs不被调度。您可能需要将固定日期设置为开始日期以及新的DAG名称。
太棒了!多谢 – Fewfy
你的default_args是什么样的?特别是你的'start_date' – Chengzhi