Airflow调度器默认情况下不会立即调度简单的DAG任务,这是因为调度器根据DAG的调度间隔和开始日期来决定何时执行任务。但是,你可以通过以下两种方法来解决这个问题:
airflow trigger_dag
可以手动触发DAG任务,如下所示:airflow trigger_dag
其中
是你要触发的DAG任务的ID。
airflow.cfg
文件中找到[scheduler]
部分,并将min_file_process_interval
参数的值设置为1分钟,如下所示:[scheduler]
...
min_file_process_interval = 60
...
保存文件后,重启Airflow调度器以使更改生效。
通过以上两种方法,你可以实现在Airflow中立即调度简单的DAG任务。