4

test1.py在目录下定义了我的 dag 文件/opt/airflow/dags。最初,该文件只有一个任务,test1_task01. 在我的 GUI 中,dag 只有一项任务才能正确显示。但是,当我向我的 DAG 添加另一个任务时,如下所示:

DAG - test1_task01 <- test2_task01 (representative - not airflow syntax)

我在我的 GUI 中没有看到更新的 DAG。GUI 仍然有旧的 DAG。airflow list_tasks <dagname>显示正确的 DAG 关系并airflow scheduler执行最新版本,但 GUI 不知何故并未提取最新信息。

如何通过 GUI 获得 DAG 的更新视图?

4

3 回答 3

1

也有可能,如果您创建新的 DAG,您可能使用了与之前成功运行的 DAG 相同的 dag_id。在这种情况下,气流 GUI 不会显示任何错误或提示为什么它没有被加载

于 2021-06-30T16:27:49.143 回答
1

更改 DAG/任务的结构后,您需要重新启动网络服务器(可能还有调度程序)才能在 gui 上看到新的更改。但是,如果还可以使用命令行界面接口>airflow list_tasks <dag_id>以及许多其他有用的命令来测试和运行新更改。

于 2016-09-30T22:46:56.817 回答
1

我在代码选项卡中遇到了这个问题,它不会更新。事实证明,由于 DAG 脚本中的错误,它没有更新。Airflow 会加载最新的有效版本,并且错误会记录在/home页面上。在那里查找,修复脚本中的问题,代码应该更新得很好。

于 2021-09-21T22:42:12.610 回答