From 7af8c5418cdcefc2e0587765065530e9259ea9eb Mon Sep 17 00:00:00 2001
From: Mohit Yadav <105265192+mohityadav766@users.noreply.github.com>
Date: Tue, 18 Oct 2022 18:59:11 +0530
Subject: [PATCH] Adding Exception to Logger , and update batch jobs status as
 well (#8217)

---
 .../elasticSearch/BuildSearchIndexResource.java       | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/elasticSearch/BuildSearchIndexResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/elasticSearch/BuildSearchIndexResource.java
index 2f35eb40b25..2a8f3b25184 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/elasticSearch/BuildSearchIndexResource.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/elasticSearch/BuildSearchIndexResource.java
@@ -31,6 +31,7 @@ import javax.ws.rs.core.Response;
 import javax.ws.rs.core.SecurityContext;
 import javax.ws.rs.core.UriInfo;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.exception.ExceptionUtils;
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.bulk.BackoffPolicy;
 import org.elasticsearch.action.bulk.BulkProcessor;
@@ -296,7 +297,13 @@ public class BuildSearchIndexResource {
         after = result.getPaging().getAfter();
       } while (after != null);
     } catch (Exception ex) {
-      LOG.error("Failed in listing all Entities of type : {}", entityType);
+      LOG.error("Failed in listing all Entities of type : {}, Reason : ", entityType, ex);
+      FailureDetails failureDetails =
+          new FailureDetails()
+              .withContext(String.format("%s:Failure in fetching Data", entityType))
+              .withLastFailedReason(
+                  String.format("Failed in listing all Entities \n Reason : %s", ExceptionUtils.getStackTrace(ex)));
+      listener.updateElasticSearchStatus(EventPublisherJob.Status.IDLE, failureDetails, null);
     }
   }
 
@@ -332,7 +339,7 @@ public class BuildSearchIndexResource {
         after = result.getPaging().getAfter();
       } while (after != null);
     } catch (Exception ex) {
-      LOG.error("Failed in listing all Entities of type : {}", entityType);
+      LOG.error("Failed in listing all Entities of type : {}, Reason {}", entityType, ex);
     }
   }