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,
 		}
 	}