Skip to content

Commit

Permalink
Fix error swallowed in the frontend. (#2807)
Browse files Browse the repository at this point in the history
Signed-off-by: Cyril Tovena <cyril.tovena@gmail.com>
  • Loading branch information
cyriltovena authored Oct 26, 2020
1 parent ecc4022 commit fa00b90
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions pkg/querier/queryrange/split_by_interval.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,8 @@ func (h *splitByInterval) Process(
parallelism int,
threshold int64,
input []*lokiResult,
) (responses []queryrange.Response, err error) {
) ([]queryrange.Response, error) {
var responses []queryrange.Response
ctx, cancel := context.WithCancel(ctx)
defer cancel()

Expand Down Expand Up @@ -111,7 +112,7 @@ func (h *splitByInterval) Process(
return nil, ctx.Err()
case data := <-x.ch:
if data.err != nil {
return nil, err
return nil, data.err
}

responses = append(responses, data.resp)
Expand Down

0 comments on commit fa00b90

Please sign in to comment.