Skip to content

Commit 28d987f

Browse files
yihzhouYihong Zhou
and
Yihong Zhou
authored
fix: skip ingestion when in process callback service return NULL (#533)
Co-authored-by: Yihong Zhou <yihzhou@yihzhou-mn2.linkedin.biz>
1 parent b03c43d commit 28d987f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

dao-api/src/main/java/com/linkedin/metadata/dao/BaseLocalDAO.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -668,7 +668,7 @@ private <ASPECT extends RecordTemplate> AddResult<ASPECT> aspectUpdateHelper(URN
668668
AspectUpdateResult result = aspectCallbackHelper(urn, newValue, oldValue, updateTuple.getIngestionParams(), auditStamp);
669669
newValue = (ASPECT) result.getUpdatedAspect();
670670
// skip the normal ingestion to the DAO
671-
if (result.isSkipProcessing()) {
671+
if (newValue == null || result.isSkipProcessing()) {
672672
return null;
673673
}
674674
}

0 commit comments

Comments
 (0)