Merge pull request #4456 from atlanhq/mesh-363-execution

PRATHAM2002-DS · web-flow · commit 4bc24e3c692f · 2025-03-13T11:26:16.000+05:30
MESH-365 : Internal-attribute mismatch error resolved
diff --git a/repository/src/main/java/org/apache/atlas/repository/businesslineage/BusinessLineageService.java b/repository/src/main/java/org/apache/atlas/repository/businesslineage/BusinessLineageService.java
@@ -235,8 +235,8 @@ public void addInputRelation(AtlasVertex assetVertex, AtlasVertex productVertex,
                     relationship.setTypeName(REL_DATA_PRODUCT_TO_INPUT_PORTS);
                     relationshipStoreV2.getOrCreate(assetVertex, productVertex, relationship, true);
                     LOG.info("Added input relation between asset and product");
+                    updateInternalAttr(productVertex, assetGuid, operation);
                 }
-                updateInternalAttr(productVertex, assetGuid, operation);
             }
         } catch (AtlasBaseException e){
             LOG.error("Error while adding input relation", e);
@@ -251,8 +251,8 @@ public void removeInputRelation(AtlasVertex assetVertex, AtlasVertex productVert
                 AtlasEdge inputPortEdge = graphHelper.getEdge(assetVertex, productVertex, INPUT_PORT_PRODUCT_EDGE_LABEL);
                 if(inputPortEdge != null){
                     graph.removeEdge(inputPortEdge);
+                    updateInternalAttr(productVertex, assetGuid, operation);
                 }
-                updateInternalAttr(productVertex, assetGuid, operation);
             }
         } catch (AtlasBaseException | RepositoryException e){
             LOG.error("Error while removing input relation", e);

Original file line number	Diff line number	Diff line change
`@@ -235,8 +235,8 @@ public void addInputRelation(AtlasVertex assetVertex, AtlasVertex productVertex,`
`235`	`235`	`relationship.setTypeName(REL_DATA_PRODUCT_TO_INPUT_PORTS);`
`236`	`236`	`relationshipStoreV2.getOrCreate(assetVertex, productVertex, relationship, true);`
`237`	`237`	`LOG.info("Added input relation between asset and product");`
	`238`	`+ updateInternalAttr(productVertex, assetGuid, operation);`
`238`	`239`	`}`
`239`		`- updateInternalAttr(productVertex, assetGuid, operation);`
`240`	`240`	`}`
`241`	`241`	`} catch (AtlasBaseException e){`
`242`	`242`	`LOG.error("Error while adding input relation", e);`
`@@ -251,8 +251,8 @@ public void removeInputRelation(AtlasVertex assetVertex, AtlasVertex productVert`
`251`	`251`	`AtlasEdge inputPortEdge = graphHelper.getEdge(assetVertex, productVertex, INPUT_PORT_PRODUCT_EDGE_LABEL);`
`252`	`252`	`if(inputPortEdge != null){`
`253`	`253`	`graph.removeEdge(inputPortEdge);`
	`254`	`+ updateInternalAttr(productVertex, assetGuid, operation);`
`254`	`255`	`}`
`255`		`- updateInternalAttr(productVertex, assetGuid, operation);`
`256`	`256`	`}`
`257`	`257`	`} catch (AtlasBaseException \| RepositoryException e){`
`258`	`258`	`LOG.error("Error while removing input relation", e);`