From ea615eed9d571ea1a1d1bf6af536e9c0d32c69f1 Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Wed, 17 May 2023 15:48:20 +0530 Subject: [PATCH] Fix elasticsearch error (#11635) --- ingestion/src/metadata/ingestion/sink/elasticsearch.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/ingestion/src/metadata/ingestion/sink/elasticsearch.py b/ingestion/src/metadata/ingestion/sink/elasticsearch.py index a1dc3d6454a..594fa02b5b1 100644 --- a/ingestion/src/metadata/ingestion/sink/elasticsearch.py +++ b/ingestion/src/metadata/ingestion/sink/elasticsearch.py @@ -65,6 +65,7 @@ from metadata.ingestion.models.es_documents import ( UserESDocument, ) from metadata.ingestion.ometa.ometa_api import OpenMetadata +from metadata.ingestion.ometa.utils import model_str from metadata.ingestion.sink.elasticsearch_mapping.container_search_index_mapping import ( CONTAINER_ELASTICSEARCH_INDEX_MAPPING, ) @@ -906,7 +907,7 @@ def _create_tag_es_doc( for tag in tag_list.entities or []: suggest = [ - ESSuggest(input=tag.fullyQualifiedName.__root__, weight=5), + ESSuggest(input=model_str(tag.fullyQualifiedName), weight=5), ESSuggest(input=tag.name.__root__, weight=10), ]