Query: fix partial response for distributed instant query

MichaHoffmann · MichaHoffmann · commit 65ee106eec93 · 2025-04-17T06:58:22.000Z
diff --git a/pkg/api/query/grpc.go b/pkg/api/query/grpc.go
@@ -120,7 +120,7 @@ func (g *GRPCAPI) Query(request *querypb.QueryRequest, server querypb.Query_Quer
 	})
 	if result.Err != nil {
 		if request.EnablePartialResponse {
-			if err := server.Send(querypb.NewQueryWarningsResponse(err)); err != nil {
+			if err := server.Send(querypb.NewQueryWarningsResponse(result.Err)); err != nil {
 				return err
 			}
 			return nil

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ func (g GRPCAPI) Query(request querypb.QueryRequest, server querypb.Query_Quer`
`120`	`120`	`})`
`121`	`121`	`if result.Err != nil {`
`122`	`122`	`if request.EnablePartialResponse {`
`123`		`- if err := server.Send(querypb.NewQueryWarningsResponse(err)); err != nil {`
	`123`	`+ if err := server.Send(querypb.NewQueryWarningsResponse(result.Err)); err != nil {`
`124`	`124`	`return err`
`125`	`125`	`}`
`126`	`126`	`return nil`