File tree Expand file tree Collapse file tree 1 file changed +8
-12
lines changed Expand file tree Collapse file tree 1 file changed +8
-12
lines changed Original file line number Diff line number Diff line change @@ -29,8 +29,8 @@ use std::pin::Pin;
2929use std:: sync:: Arc ;
3030use std:: time:: Instant ;
3131
32- use arrow_schema:: Schema ;
3332use crate :: handlers:: http:: send_schema_request;
33+ use arrow_schema:: Schema ;
3434
3535use crate :: event:: commit_schema;
3636use crate :: metrics:: QUERY_EXECUTE_TIME ;
@@ -80,20 +80,16 @@ pub async fn query(req: HttpRequest, query_request: Query) -> Result<impl Respon
8080 }
8181 }
8282
83- let mmem = if CONFIG . parseable . mode == Mode :: Query {
83+ let mut mmem = None ;
84+
85+ if CONFIG . parseable . mode == Mode :: Query {
8486 // create a new query to send to the ingestors
8587 if let Some ( que) = transform_query_for_ingestor ( & query_request) {
86- let vals = send_request_to_ingestor ( & que)
87- . await
88- . map_err ( |err| QueryError :: Custom ( err. to_string ( ) ) ) ?;
89-
90- Some ( vals)
91- } else {
92- None
88+ if let Ok ( vals) = send_request_to_ingestor ( & que) . await {
89+ mmem = Some ( vals) ;
90+ }
9391 }
94- } else {
95- None
96- } ;
92+ }
9793
9894 let creds = extract_session_key_from_req ( & req) . expect ( "expects basic auth" ) ;
9995 let permissions = Users . get_permissions ( & creds) ;
You can’t perform that action at this time.
0 commit comments