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