diff --git a/pkg/promlib/querydata/request.go b/pkg/promlib/querydata/request.go
index 5ed665ea4e2..625113a69c9 100644
--- a/pkg/promlib/querydata/request.go
+++ b/pkg/promlib/querydata/request.go
@@ -235,9 +235,8 @@ 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,
-			ErrorSource: backend.ErrorSourceDownstream,
+			Error:  err,
+			Status: backend.StatusBadGateway,
 		}
 	}
 
@@ -255,17 +254,15 @@ 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,
-			ErrorSource: backend.ErrorSourceDownstream,
+			Error:  err,
+			Status: backend.StatusBadGateway,
 		}
 	}
 
 	// This is only for health check fall back scenario
 	if res.StatusCode != 200 && q.RefId == "__healthcheck__" {
 		return backend.DataResponse{
-			Error:       errors.New(res.Status),
-			ErrorSource: backend.ErrorSourceDownstream,
+			Error: errors.New(res.Status),
 		}
 	}
 
@@ -283,8 +280,7 @@ 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,
-			ErrorSource: backend.ErrorSourceDownstream,
+			Error: err,
 		}
 	}