chore: refactor

server/src/handlers/http/query.rs

@@ -29,8 +29,8 @@ use std::pin::Pin;
 use std::sync::Arc;
 use std::time::Instant;
 
-use arrow_schema::Schema;
 use crate::handlers::http::send_schema_request;
+use arrow_schema::Schema;
 
 use crate::event::commit_schema;
 use crate::metrics::QUERY_EXECUTE_TIME;
@@ -80,20 +80,16 @@ pub async fn query(req: HttpRequest, query_request: Query) -> Result<impl Respon
         }
     }
 
-    let mmem = if CONFIG.parseable.mode == Mode::Query {
+    let mut mmem = None;
+
+    if CONFIG.parseable.mode == Mode::Query {
         // create a new query to send to the ingestors
         if let Some(que) = transform_query_for_ingestor(&query_request) {
-            let vals = send_request_to_ingestor(&que)
-                .await
-                .map_err(|err| QueryError::Custom(err.to_string()))?;
-
-            Some(vals)
-        } else {
-            None
+            if let Ok(vals) = send_request_to_ingestor(&que).await {
+                mmem = Some(vals);
+            }
         }
-    } else {
-        None
-    };
+    }
 
     let creds = extract_session_key_from_req(&req).expect("expects basic auth");
     let permissions = Users.get_permissions(&creds);