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), ]