Bug fix

Signed-off-by: Muhammad Mikaal S. Anwar <[email protected]>
amundsen-io · Sep 21, 2023 · 74f8fc5 · 74f8fc5
1 parent 1edf9cd
commit 74f8fc5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/search/search_service/proxy/es_proxy_v2_1.py b/search/search_service/proxy/es_proxy_v2_1.py
@@ -364,16 +364,17 @@ def search(self, *,
 
         for resource in resource_types:
             # guard clause to prevent search in missing indices or aliases
-            aliases_in_es = self.elasticsearch.indices.get_alias().keys()
-            if self.get_index_alias_for_resource(resource_type=resource) not in aliases_in_es:
+            aliases_in_es = {alias['alias'] for alias in self.elasticsearch.cat.aliases(format="json")}
+            resource_alias = self.get_index_alias_for_resource(resource_type=resource)
+            if resource_alias not in aliases_in_es:
                 continue
 
             # build a query for each resource to search
             query_for_resource = self._build_elasticsearch_query(resource=resource,
                                                                  query_term=query_term,
                                                                  filters=filters)
             # wrap the query in a search object
-            search = Search(index=self.get_index_alias_for_resource(resource_type=resource)).query(query_for_resource)
+            search = Search(index=resource_alias).query(query_for_resource)
 
             # highlighting
             if highlight_options: