diff --git a/cmd/ingestor.logs.ethereum/func.go b/cmd/ingestor.logs.ethereum/func.go
index 1d56be3f..f70ebe37 100644
--- a/cmd/ingestor.logs.ethereum/func.go
+++ b/cmd/ingestor.logs.ethereum/func.go
@@ -249,7 +249,7 @@ func handleLogCallback(seawaterAddr, thirdwebAddr, leoAddr ethCommon.Address, l
 		isSeawater = false
 		isLeo = true
 
-	case leo.TopicPositionDivested:
+	case leo.TopicPositionDivested2:
 		a, err = leo.UnpackPositionDivested2(topic1, topic2, topic3, data)
 		logEvent("PositionDivested2")
 		table = "events_leo_positiondivested2"
diff --git a/lib/events/leo/leo.go b/lib/events/leo/leo.go
index c29492c1..de86cd46 100644
--- a/lib/events/leo/leo.go
+++ b/lib/events/leo/leo.go
@@ -98,7 +98,7 @@ func UnpackPositionVested2(topic1, topic2, topic3 ethCommon.Hash, d []byte) (*Po
 	}, nil
 }
 
-func UnpackPositionDivested2(topic1, topic2, topic3 ethCommon.Hash, d []byte) (*PositionDivested, error) {
+func UnpackPositionDivested2(topic1, topic2, topic3 ethCommon.Hash, d []byte) (*PositionDivested2, error) {
 	return &PositionDivested2{
 		PositionId: hashToNumber(topic1),
 		Recipient:  hashToAddr(topic2),