Added error handling (#4252)

ingestion/src/metadata/ingestion/ometa/mixins/es_mixin.py

@@ -50,15 +50,21 @@ class ESMixin(Generic[T]):
                 if value is not None
             ]
         )
+        multiple_entities = []
+        try:
             resp_es = self.client.get(
                 self.es_url.format(
                     service_name, generate_es_string, from_count, size, search_index
                 )
             )
-        multiple_entities = []
+
             if resp_es:
                 for table_hit in resp_es["hits"]["hits"]:
                     multiple_entities.append(
-                    self.get_by_name(entity=Table, fqdn=table_hit["_source"]["fqdn"])
+                        self.get_by_name(
+                            entity=Table, fqdn=table_hit["_source"]["fqdn"]
                         )
+                    )
+        except Exception as err:
+            logger.error(f"Elasticsearch failed for query: {generate_es_string}")
         return multiple_entities

ingestion/src/metadata/ingestion/ometa/mixins/lineage_mixin.py

@@ -243,4 +243,5 @@ class OMetaLineageMixin(Generic[T]):
                         )
             return True
         except Exception as err:
-            logger.error(str(err))
+            logger.debug(str(err))
+            logger.error(f"Ingesting lineage failed")