reorganize all imports

src/api/jobs.rs

@@ -1,12 +1,10 @@
-use snafu::Report;
-use snafu::{ResultExt, Snafu};
 use std::{sync::Arc, time::Duration};
-use tracing::error;
 
+use snafu::{Report, ResultExt, Snafu};
+use tracing::error;
 use uuid::Uuid;
 
-use crate::storage;
+use crate::{storage, storage::jobs::AddError};
-use crate::storage::jobs::AddError;
 
 /// Manage background job execution and storage.
 #[derive(Clone, Debug)]

src/api/state.rs

@@ -1,8 +1,7 @@
 //! Shared application state for HTTP handlers.
 
-use crate::{storage::Postgres, text_encoder::TextEncoder, tokenize::Tokenizer};
-
 use super::jobs::JobManager;
+use crate::{storage::Postgres, text_encoder::TextEncoder, tokenize::Tokenizer};
 
 /// Application state shared across all HTTP request handlers.
 #[derive(Debug, Clone)]

src/query.rs

@@ -58,12 +58,11 @@ pub async fn ask(
     let reranker = reranker.clone();
     let tokenizer = tokenizer.clone();
     let query = query.to_string();
-    let reranked_docs = tokio::task::spawn_blocking(move || {
+    let reranked_docs =
-        reranker.rerank(&query, documents, &tokenizer, limit)
+        tokio::task::spawn_blocking(move || reranker.rerank(&query, documents, &tokenizer, limit))
-    })
+            .await
-    .await
+            .context(RerankJoinSnafu)?
-    .context(RerankJoinSnafu)?
+            .context(RerankSnafu)?;
-    .context(RerankSnafu)?;
 
     Ok(reranked_docs)
 }