Dag에 태그를 추가하고 UI에서 필터링하기

Dag마다 태그를 추가하면 UI에서 팀별로 Dag를 필터링할 수 있어요. 이 문서에서는 Dag 객체에 tags 목록을 전달하는 방법과, 오래된 태그를 정리하는 방법을 간단히 살펴볼게요.

출처: 문서

본문

1.10.8 버전에 추가됨 (Added in version 1.10.8).

Dag를 (예: 팀별로) 필터링하기 위해 각 Dag에 태그를 추가할 수 있어요. 필터는 쿠키에 저장되고, 리셋 버튼으로 초기화할 수 있어요.

예를 들어 볼게요:

Dag 파일에서 Dag 객체에 추가하고 싶은 태그 목록을 전달해요:

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

스크린샷:

태그는 Dag 파싱의 일부로 등록돼요. 오래된(stale) 태그가 남아 있다면 Airflow CLI 명령 airflow db clean으로 오래된 데이터를 정리할 수 있어요. 자세한 내용은 db clean 사용법을 확인해 보세요.