added filter for vector lengths

Author: darkcoderrises

posting/index.go

@@ -110,19 +110,16 @@ func (mp *MutationPipeline) InsertTokenizerIndexes(ctx context.Context, pipeline
 		pipeline.errCh <- err
 		return
 	}
-	indexEdge := &pb.DirectedEdge{
-		Attr: pipeline.attr,
-	}
+
 	if len(tokenizers) == 0 {
 		return
 	}
 
 	values := make(map[string]*pb.PostingList, len(tokenizers)*len(*postings))
 	valPost := make(map[string]*pb.Posting)
-	info := &indexMutationInfo{
-		tokenizers:   tokenizers,
-		factorySpecs: factorySpecs,
-		op:           pb.DirectedEdge_SET,
+
+	indexEdge1 := &pb.DirectedEdge{
+		Attr: pipeline.attr,
 	}
 
 	for uid, postingList := range *postings {
@@ -133,10 +130,10 @@ func (mp *MutationPipeline) InsertTokenizerIndexes(ctx context.Context, pipeline
 				valPl = &pb.PostingList{}
 			}
 
-			indexEdge.Op = GetPostingOp(posting.Op)
-			indexEdge.ValueId = uid
+			indexEdge1.Op = GetPostingOp(posting.Op)
+			indexEdge1.ValueId = uid
 
-			mpost := makePostingFromEdge(mp.txn.StartTs, indexEdge)
+			mpost := makePostingFromEdge(mp.txn.StartTs, indexEdge1)
 			valPl.Postings = append(valPl.Postings, mpost)
 			values[string(posting.Value)] = valPl
 
@@ -158,8 +155,19 @@ func (mp *MutationPipeline) InsertTokenizerIndexes(ctx context.Context, pipeline
 	f := func(numGo int) *types.LockedShardedMap[string, *pb.PostingList] {
 		wg := &sync.WaitGroup{}
 
+		indexEdge := &pb.DirectedEdge{
+			Attr: pipeline.attr,
+		}
+
 		globalMap := types.NewLockedShardedMap[string, *pb.PostingList]()
 		process := func(start int) {
+
+			info := &indexMutationInfo{
+				tokenizers:   tokenizers,
+				factorySpecs: factorySpecs,
+				op:           pb.DirectedEdge_SET,
+			}
+
 			defer wg.Done()
 			localMap := make(map[string]*pb.PostingList, len(values)/numGo)
 			for i := start; i < len(values); i += numGo {