From 506f2783ccbb3724871c2cdda62b98b5e86de0b4 Mon Sep 17 00:00:00 2001 From: adetunjii Date: Tue, 12 Sep 2023 10:29:42 +0100 Subject: [PATCH] fix: ConsumeValues in aggreagation stage --- internal/handlers/common/aggregations/stages/group.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/internal/handlers/common/aggregations/stages/group.go b/internal/handlers/common/aggregations/stages/group.go index 82785c0f149..2a35356623b 100644 --- a/internal/handlers/common/aggregations/stages/group.go +++ b/internal/handlers/common/aggregations/stages/group.go @@ -118,7 +118,6 @@ func newGroup(stage *types.Document) (aggregations.Stage, error) { // Process implements Stage interface. func (g *group) Process(ctx context.Context, iter types.DocumentsIterator, closer *iterator.MultiCloser) (types.DocumentsIterator, error) { //nolint:lll // for readability - groupedDocuments, err := g.groupDocuments(iter) if err != nil { return nil, err @@ -231,7 +230,6 @@ func (g *group) groupDocuments(iter types.DocumentsIterator) ([]groupedDocuments var m groupMap for { - _, doc, err := iter.Next() if errors.Is(err, iterator.ErrIteratorDone) { break