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
index f99d1659c2..b48dd18822 100644
--- 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
@@ -2698,8 +2698,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;
+                    }
                 }
             }