diff --git a/pkg/lokifrontend/frontend/v2/frontend_scheduler_worker.go b/pkg/lokifrontend/frontend/v2/frontend_scheduler_worker.go index 68a535b977..895bdfb98e 100644 --- a/pkg/lokifrontend/frontend/v2/frontend_scheduler_worker.go +++ b/pkg/lokifrontend/frontend/v2/frontend_scheduler_worker.go @@ -311,7 +311,7 @@ func (w *frontendSchedulerWorker) schedulerLoop(loop schedulerpb.SchedulerForFro req.response <- &frontendv2pb.QueryResultRequest{ HttpResponse: &httpgrpc.HTTPResponse{ Code: http.StatusInternalServerError, - Body: []byte(err.Error()), + Body: []byte(resp.Error), }, }