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
index d669307cde..93a97687fd 100644
--- a/repository/src/main/java/org/apache/atlas/repository/businesslineage/BusinessLineageService.java
+++ b/repository/src/main/java/org/apache/atlas/repository/businesslineage/BusinessLineageService.java
@@ -125,8 +125,8 @@ public void createLineage(BusinessLineageRequest request) throws AtlasBaseExcept
                     processProductAssetInputRelation(assetGuid, productGuid, operation, edgeLabel);
                 }
             }
-            handleEntityMutation(updatedVertices);
             commitChanges();
+            handleEntityMutation(updatedVertices);
         } catch (AtlasBaseException | RepositoryException e){
             LOG.error("Error while creating lineage", e);
             throw e;