我在目录test1.py下定义了dag 文件/opt/airflow/dags。最初,该文件只有一个任务,test1_task01. 在我的 GUI 中,dag 仅在一项任务中正确显示。但是,当我向 DAG 添加另一个任务时,如下所示:
DAG - test1_task01 <- test2_task01 (representative - not airflow syntax)
Run Code Online (Sandbox Code Playgroud)
我在 GUI 中没有看到更新的 DAG。GUI 仍然具有旧的 DAG。airflow list_tasks <dagname>显示正确的 DAG 关系并airflow scheduler执行最新版本,但 GUI 不知何故没有提取最新信息。
如何通过 GUI 获取 DAG 的更新视图?
我们正在使用Airflow v 1.9.0。我们有100多个dag,实例速度非常慢。调度程序仅启动一些任务。
为了减少CPU使用量,我们想调整一些配置参数,即:min_file_process_interval和dag_dir_list_interval。该文件并没有真正明确了两者的区别
airflow ×2