向 DAG 添加标签并在用户界面中使用它进行过滤¶
1.10.8 版本的新功能。
为了过滤 DAG(例如按团队过滤),您可以在每个 DAG 中添加标签。过滤器保存在 cookie 中,可以通过重置按钮重置。
例如
在您的 DAG 文件中,传递要添加到 DAG 对象的标签列表
dag = DAG(dag_id="example_dag_tag", schedule="0 0 * * *", tags=["example"])
屏幕截图:
标签在 DAG 解析过程中注册。如果标签过时,您可以使用 Airflow CLI 命令 airflow db clean
清除旧数据。有关更多详细信息,请参阅 db clean 用法。