mirror of
https://github.com/aljazceru/turso.git
synced 2025-12-17 08:34:19 +01:00
fix fmt and test
This commit is contained in:
@@ -796,12 +796,13 @@ impl IndexMethodCursor for VectorSparseInvertedIndexMethodCursor {
|
||||
};
|
||||
}
|
||||
SeekResult::TryAdvance => {
|
||||
self.delete_state = VectorSparseInvertedIndexDeleteState::NextInverted {
|
||||
vector: vector.take(),
|
||||
sum: *sum,
|
||||
idx: *idx,
|
||||
rowid: *rowid,
|
||||
};
|
||||
self.delete_state =
|
||||
VectorSparseInvertedIndexDeleteState::NextInverted {
|
||||
vector: vector.take(),
|
||||
sum: *sum,
|
||||
idx: *idx,
|
||||
rowid: *rowid,
|
||||
};
|
||||
}
|
||||
SeekResult::NotFound => {
|
||||
return Err(LimboError::Corrupt("inverted index corrupted".to_string()))
|
||||
|
||||
@@ -75,7 +75,10 @@ fn test_vector_sparse_ivf_create_destroy() {
|
||||
run(&tmp_db, || cursor.create(&conn)).unwrap();
|
||||
}
|
||||
conn.wal_insert_end(true).unwrap();
|
||||
assert_eq!(schema_rows(), vec!["t", "t_idx_scratch", "t_idx_stats"]);
|
||||
assert_eq!(
|
||||
schema_rows(),
|
||||
vec!["t", "t_idx_inverted_index", "t_idx_stats"]
|
||||
);
|
||||
|
||||
conn.wal_insert_begin().unwrap();
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user