From a6dd100be4986dfce4c552a4a7e962ff8be1f40d Mon Sep 17 00:00:00 2001 From: Pere Miquel Brull Date: Thu, 7 Jul 2022 21:15:09 +0200 Subject: [PATCH] Fix metadata es DAG (#5933) --- ingestion/examples/airflow/dags/airflow_metadata_to_es.py | 2 +- ingestion/src/metadata/ingestion/sink/elasticsearch.py | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/ingestion/examples/airflow/dags/airflow_metadata_to_es.py b/ingestion/examples/airflow/dags/airflow_metadata_to_es.py index fbbfa9656bd..9fa56c2d7c5 100644 --- a/ingestion/examples/airflow/dags/airflow_metadata_to_es.py +++ b/ingestion/examples/airflow/dags/airflow_metadata_to_es.py @@ -49,7 +49,7 @@ config = """ "sourceConfig":{"config":{}} }, "sink": { - "type": "elasticsearch_mapping", + "type": "elasticsearch", "config": { "index_tables": "true", "index_topics": "true", diff --git a/ingestion/src/metadata/ingestion/sink/elasticsearch.py b/ingestion/src/metadata/ingestion/sink/elasticsearch.py index 860969ae902..380045d8412 100644 --- a/ingestion/src/metadata/ingestion/sink/elasticsearch.py +++ b/ingestion/src/metadata/ingestion/sink/elasticsearch.py @@ -35,7 +35,6 @@ from metadata.generated.schema.entity.services.connections.metadata.openMetadata from metadata.generated.schema.entity.tags.tagCategory import TagCategory from metadata.generated.schema.entity.teams.team import Team from metadata.generated.schema.entity.teams.user import User -from metadata.generated.schema.type import entityReference from metadata.generated.schema.type.entityReference import EntityReference from metadata.ingestion.api.common import Entity from metadata.ingestion.api.sink import Sink, SinkStatus