added filter for vector lengths

Author: darkcoderrises

posting/index.go

@@ -155,9 +155,6 @@ 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) {
@@ -168,6 +165,10 @@ func (mp *MutationPipeline) InsertTokenizerIndexes(ctx context.Context, pipeline
 				op:           pb.DirectedEdge_SET,
 			}
 
+			indexEdge := &pb.DirectedEdge{
+				Attr: pipeline.attr,
+			}
+
 			defer wg.Done()
 			localMap := make(map[string]*pb.PostingList, len(values)/numGo)
 			for i := start; i < len(values); i += numGo {