From b9b5445090a9de0181611419028d52dd2271f00c Mon Sep 17 00:00:00 2001 From: Brendan O'Handley Date: Thu, 7 Nov 2024 08:59:53 -0600 Subject: [PATCH] Prometheus: Add error source to differentiate errors for api server work (#95999) add error source to differentiate errors for api server work --- pkg/promlib/querydata/request.go | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/pkg/promlib/querydata/request.go b/pkg/promlib/querydata/request.go index 625113a69c9..5ed665ea4e2 100644 --- a/pkg/promlib/querydata/request.go +++ b/pkg/promlib/querydata/request.go @@ -235,8 +235,9 @@ func (s *QueryData) rangeQuery(ctx context.Context, c *client.Client, q *models. res, err := c.QueryRange(ctx, q) if err != nil { return backend.DataResponse{ - Error: err, - Status: backend.StatusBadGateway, + Error: err, + Status: backend.StatusBadGateway, + ErrorSource: backend.ErrorSourceDownstream, } } @@ -254,15 +255,17 @@ func (s *QueryData) instantQuery(ctx context.Context, c *client.Client, q *model res, err := c.QueryInstant(ctx, q) if err != nil { return backend.DataResponse{ - Error: err, - Status: backend.StatusBadGateway, + Error: err, + Status: backend.StatusBadGateway, + ErrorSource: backend.ErrorSourceDownstream, } } // This is only for health check fall back scenario if res.StatusCode != 200 && q.RefId == "__healthcheck__" { return backend.DataResponse{ - Error: errors.New(res.Status), + Error: errors.New(res.Status), + ErrorSource: backend.ErrorSourceDownstream, } } @@ -280,7 +283,8 @@ func (s *QueryData) exemplarQuery(ctx context.Context, c *client.Client, q *mode res, err := c.QueryExemplars(ctx, q) if err != nil { return backend.DataResponse{ - Error: err, + Error: err, + ErrorSource: backend.ErrorSourceDownstream, } }