Content
@task
References
Internal DB details
New in version 1.10.8.
In order to filter DAGs (e.g by team), you can add tags in each DAG. The filter is saved in a cookie and can be reset by the reset button.
For example:
In your Dag file, pass a list of tags you want to add to DAG object:
dag = DAG(dag_id="example_dag_tag", schedule="0 0 * * *", tags=["example"])
Screenshot:
Tags are registered as part of dag parsing. In case of stale tags, you can purge old data with the Airflow CLI command airflow db clean. See db clean usage for more details.
airflow db clean
Was this entry helpful?