Issue #28: throw the errors coming from quickwit

quickwit-oss · Nov 24, 2023 · 3af16ad · 3af16ad
1 parent 271eda2
commit 3af16ad
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/quickwit/client/client.go b/pkg/quickwit/client/client.go
@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"context"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"net/http"
 	"net/url"
@@ -170,7 +171,9 @@ func (c *baseClientImpl) ExecuteMultisearch(r *MultiSearchRequest) (*MultiSearch
 		jsonResponseBody, _ := json.Marshal(res.Body)
 		jsonQueryParam, _ := json.Marshal(queryParams)
 		jsonRequestBody, _ := json.Marshal(r.Requests)
-		c.logger.Error("Error on multisearch: statusCode = " + strconv.Itoa(res.StatusCode) + ", responseBody = " + string(jsonResponseBody) + ", queryParam = " + string(jsonQueryParam) + ", requestBody = " + string(jsonRequestBody))
+		err_msg := "Error on multisearch: statusCode = " + strconv.Itoa(res.StatusCode) + ", responseBody = " + string(jsonResponseBody) + ", queryParam = " + string(jsonQueryParam) + ", requestBody = " + string(jsonRequestBody)
+		c.logger.Error(err_msg)
+		return nil, errors.New(err_msg)
 	}
 
 	start := time.Now()