DG-1697: Adding endpoint for linking/unlink policy

atlanhq · Jul 3, 2024 · 4aa2131 · 4aa2131
1 parent 06a89f0
commit 4aa2131
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasEntityStoreV2.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasEntityStoreV2.java
@@ -1550,8 +1550,8 @@ private EntityMutationResponse createOrUpdate(EntityStream entityStream, boolean
 
 
             // Notify the change listeners
-           // entityChangeNotifier.onEntitiesMutated(ret, RequestContext.get().isImportInProgress());
-           // atlasRelationshipStore.onRelationshipsMutated(RequestContext.get().getRelationshipMutationMap());
+             entityChangeNotifier.onEntitiesMutated(ret, RequestContext.get().isImportInProgress());
+             atlasRelationshipStore.onRelationshipsMutated(RequestContext.get().getRelationshipMutationMap());
             if (LOG.isDebugEnabled()) {
                 LOG.debug("<== createOrUpdate()");
             }