diff --git a/query/bridges.go b/query/bridges.go index ef2df5a93bf..2aa7c2059fb 100644 --- a/query/bridges.go +++ b/query/bridges.go @@ -85,10 +85,10 @@ func (b ProxyQueryServiceAsyncBridge) Query(ctx context.Context, w io.Writer, re defer results.Release() encoder := req.Dialect.Encoder() - _, err = encoder.Encode(w, results) - if err != nil { + if _, err := encoder.Encode(w, results); err != nil { return flux.Statistics{}, tracing.LogError(span, err) } + results.Release() stats := results.Statistics() return stats, nil