From b5fa5408d518dc8c2f68953516049f97033480d8 Mon Sep 17 00:00:00 2001 From: Pere Miquel Brull Date: Mon, 13 May 2024 10:16:55 +0200 Subject: [PATCH] MINOR - Add labels in OM Airflow DAGs --- .../openmetadata_managed_apis/workflows/ingestion/common.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py index f33bb027016c..06439f80e52b 100644 --- a/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py +++ b/openmetadata-airflow-apis/openmetadata_managed_apis/workflows/ingestion/common.py @@ -255,7 +255,9 @@ def build_dag_configs(ingestion_pipeline: IngestionPipeline) -> dict: "schedule_interval": ingestion_pipeline.airflowConfig.scheduleInterval, "tags": [ "OpenMetadata", + ingestion_pipeline.displayName or ingestion_pipeline.name.__root__, ingestion_pipeline.pipelineType.value, + ingestion_pipeline.service.name, ], }