向 DAG 添加标签并在用户界面中使用它进行过滤

1.10.8 版本的新功能。

为了过滤 DAG(例如按团队过滤),您可以在每个 DAG 中添加标签。过滤器保存在 cookie 中,可以通过重置按钮重置。

例如

在您的 DAG 文件中,传递要添加到 DAG 对象的标签列表

dag = DAG(dag_id="example_dag_tag", schedule="0 0 * * *", tags=["example"])

屏幕截图:

../_images/add-dag-tags.png

标签在 DAG 解析过程中注册。如果标签过时,您可以使用 Airflow CLI 命令 airflow db clean 清除旧数据。有关更多详细信息,请参阅 db clean 用法

此条目有帮助吗?