Merge pull request #4043 from atlanhq/dg1996

When fixing hasLineage for an asset, only edge status is being checke…
atlanhq · Jan 28, 2025 · 32df511 · 32df511
2 parents 51c8986 + e388c82
commit 32df511
Showing 1 changed file with 9 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
@@ -2705,8 +2705,15 @@ private void repairHasLineageForAsset(AtlasHasLineageRequest request) {
             while (lineageEdges.hasNext()) {
                 AtlasEdge edge = lineageEdges.next();
                 if (getStatus(edge) == ACTIVE) {
-                    foundActiveRel = true;
-                    break;
+                    AtlasVertex vertexB = edge.getOutVertex();
+                    if (vertexB.equals(assetVertex)) {
+                        vertexB = edge.getInVertex();
+                    }
+
+                    if (getStatus(vertexB) == ACTIVE) {
+                        foundActiveRel = true;
+                        break;
+                    }
                 }
             }