Fix Glossary tree hierarchy state

openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/WorkflowEventConsumer.java

@@ -1,9 +1,12 @@
 package org.openmetadata.service.governance.workflows;
 
+import static org.openmetadata.schema.entity.events.SubscriptionDestination.SubscriptionType.GOVERNANCE_WORKFLOW_CHANGE_EVENT;
+
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.tuple.Pair;
 import org.openmetadata.schema.entity.events.EventSubscription;
 import org.openmetadata.schema.entity.events.SubscriptionDestination;
 import org.openmetadata.schema.type.ChangeEvent;
@@ -13,6 +16,7 @@
 import org.openmetadata.service.Entity;
 import org.openmetadata.service.apps.bundles.changeEvent.Destination;
 import org.openmetadata.service.events.errors.EventPublisherException;
+import org.openmetadata.service.exception.CatalogExceptionMessage;
 import org.openmetadata.service.resources.feeds.MessageParser;
 
 @Slf4j
@@ -46,22 +50,33 @@ public WorkflowEventConsumer(
   @Override
   public void sendMessage(ChangeEvent event) throws EventPublisherException {
     // NOTE: We are only consuming ENTITY related events.
-    EventType eventType = event.getEventType();
-
-    if (validEventTypes.contains(eventType)) {
-      String signal = String.format("%s-%s", event.getEntityType(), eventType.toString());
-
-      EntityReference entityReference =
-          Entity.getEntityReferenceById(event.getEntityType(), event.getEntityId(), Include.ALL);
-      MessageParser.EntityLink entityLink =
-          new MessageParser.EntityLink(
-              event.getEntityType(), entityReference.getFullyQualifiedName());
-
-      Map<String, Object> variables = new HashMap<>();
-
-      variables.put("relatedEntity", entityLink.getLinkString());
-
-      WorkflowHandler.getInstance().triggerWithSignal(signal, variables);
+    try {
+      EventType eventType = event.getEventType();
+
+      if (validEventTypes.contains(eventType)) {
+        String signal = String.format("%s-%s", event.getEntityType(), eventType.toString());
+
+        EntityReference entityReference =
+            Entity.getEntityReferenceById(event.getEntityType(), event.getEntityId(), Include.ALL);
+        MessageParser.EntityLink entityLink =
+            new MessageParser.EntityLink(
+                event.getEntityType(), entityReference.getFullyQualifiedName());
+
+        Map<String, Object> variables = new HashMap<>();
+
+        variables.put("relatedEntity", entityLink.getLinkString());
+
+        WorkflowHandler.getInstance().triggerWithSignal(signal, variables);
+      }
+    } catch (Exception exc) {
+      String message =
+          CatalogExceptionMessage.eventPublisherFailedToPublish(
+              GOVERNANCE_WORKFLOW_CHANGE_EVENT, event, exc.getMessage());
+      LOG.error(message);
+      throw new EventPublisherException(
+          CatalogExceptionMessage.eventPublisherFailedToPublish(
+              GOVERNANCE_WORKFLOW_CHANGE_EVENT, exc.getMessage()),
+          Pair.of(subscriptionDestination.getId(), event));
     }
   }