Merge pull request #3778 from atlanhq/mesh-283

MESH-283 : Unlink domain from asset to delete
atlanhq · Nov 20, 2024 · cf90e1c · cf90e1c
2 parents 4c992ae + 09adb51
commit cf90e1c
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/.../main/java/org/apache/atlas/repository/store/graph/v2/preprocessor/AssetPreProcessor.java b/.../main/java/org/apache/atlas/repository/store/graph/v2/preprocessor/AssetPreProcessor.java
@@ -61,6 +61,9 @@ public void processAttributes(AtlasStruct entityStruct, EntityMutationContext co
             case UPDATE:
                 processUpdateAsset(entity, vertex);
                 break;
+            case DELETE:
+                processDelete(vertex);
+                break;
         }
     }
 
@@ -116,6 +119,14 @@ private void validateDomainAssetLinks(AtlasEntity entity) throws AtlasBaseExcept
         }
     }
 
+    @Override
+    public void processDelete(AtlasVertex vertex) throws AtlasBaseException {
+        //remove the domain link
+        if (vertex != null) {
+            vertex.removeProperty(DOMAIN_GUIDS);
+        }
+    }
+
     private void isAuthorized(AtlasVertex vertex) throws AtlasBaseException {
         AtlasEntityHeader sourceEntity = retrieverNoRelation.toAtlasEntityHeaderWithClassifications(vertex);