starred/minne
1
0
Fork 0
mirror of https://github.com/perstarkse/minne.git synced 2026-07-02 19:11:43 +02:00
Code Issues Packages Projects Releases 10 Wiki Activity

faster index creation

Browse Source
This commit is contained in:
Per Stark
2025-12-09 21:32:23 +01:00
parent a090a8c76e
commit 2e2ea0c4ff
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/storage/indexes.rs
+6 -6
View File
@@ -14,11 +14,11 @@ use anyhow::{Context, Result};
use futures::future::try_join_all; use futures::future::try_join_all;
use serde::Deserialize; use serde::Deserialize;
use serde_json::Value; use serde_json::Value;
use tracing::{info, warn}; use tracing::{debug, info, warn};
use crate::{error::AppError, storage::db::SurrealDbClient}; use crate::{error::AppError, storage::db::SurrealDbClient};
const INDEX_POLL_INTERVAL: Duration = Duration::from_secs(2); const INDEX_POLL_INTERVAL: Duration = Duration::from_millis(50);
const FTS_ANALYZER_NAME: &str = "app_en_fts_analyzer"; const FTS_ANALYZER_NAME: &str = "app_en_fts_analyzer";
#[derive(Clone, Copy)] #[derive(Clone, Copy)]
@@ -314,7 +314,7 @@ async fn create_index_with_polling(
} }
} }
info!( debug!(
index = %index_name, index = %index_name,
table = %table, table = %table,
expected_rows = ?expected_total, expected_rows = ?expected_total,
@@ -356,7 +356,7 @@ async fn poll_index_build_status(
}; };
match snapshot.progress_pct { match snapshot.progress_pct {
Some(pct) => info!( Some(pct) => debug!(
index = %index_name, index = %index_name,
table = %table, table = %table,
status = snapshot.status, status = snapshot.status,
@@ -368,7 +368,7 @@ async fn poll_index_build_status(
progress_pct = format_args!("{pct:.1}"), progress_pct = format_args!("{pct:.1}"),
"Index build status" "Index build status"
), ),
None => info!( None => debug!(
index = %index_name, index = %index_name,
table = %table, table = %table,
status = snapshot.status, status = snapshot.status,
@@ -381,7 +381,7 @@ async fn poll_index_build_status(
} }
if snapshot.is_ready() { if snapshot.is_ready() {
info!( debug!(
index = %index_name, index = %index_name,
table = %table, table = %table,
elapsed = ?started_at.elapsed(), elapsed = ?started_at.elapsed(),