MINOR - Add labels in OM Airflow DAGs

open-metadata · May 13, 2024 · b5fa540 · b5fa540
1 parent 4f9415f
commit b5fa540
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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,
  ],
  }