DG-1697: Adding endpoint for linking/unlink policy

atlanhq · Jul 12, 2024 · 9f3282c · 9f3282c
1 parent 7e6009b
commit 9f3282c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java b/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java
@@ -174,7 +174,7 @@ private void notifyEntityEvents(List<AtlasEntity> entities, OperationType operat
              }
 
         }
-
+        LOG.info("Arpit has reached till send notification size: {} content: {} ", messages.size(), messages.get(0).toString());
         sendNotifications(operationType, messages);
         RequestContext.get().endMetricRecord(metric);
     }
@@ -245,6 +245,7 @@ private void sendNotifications(OperationType operationType, List<EntityNotificat
                     notificationSender.send(operationType, messages);
                 }
             } catch (NotificationException e) {
+                LOG.error("Arpit has reached till check - error:", e);
                 throw new AtlasBaseException(AtlasErrorCode.ENTITY_NOTIFICATION_FAILED, e, operationType.name());
             }
         }