Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion rust-toolchain.toml
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# We keep this pinned to keep clippy and rustfmt in sync between local and CI.
# Feel free to upgrade to bring in new lints.
[toolchain]
channel = "1.91.0"
channel = "1.94.0"
components = ["rustfmt", "clippy", "rust-analyzer"]
5 changes: 3 additions & 2 deletions rust/lance/benches/distributed_vector_build.rs
Original file line number Diff line number Diff line change
Expand Up @@ -281,7 +281,8 @@ async fn build_partial_fixture(dataset: &mut Dataset, bench_case: BenchCase) ->
}

let fragment_groups = contiguous_fragment_groups(dataset, bench_case.num_shards);
let (ivf_params, pq_params) = train_shared_ivf_pq(dataset, bench_case.num_partitions).await;
let (ivf_params, pq_params) =
Box::pin(train_shared_ivf_pq(dataset, bench_case.num_partitions)).await;
let params = VectorIndexParams::with_ivf_pq_params(DistanceType::L2, ivf_params, pq_params);

for fragments in fragment_groups {
Expand All @@ -290,7 +291,7 @@ async fn build_partial_fixture(dataset: &mut Dataset, bench_case: BenchCase) ->
.name("distributed_merge_only".to_string())
.fragments(fragments)
.index_uuid(fixture_uuid.to_string());
builder.execute_uncommitted().await.unwrap();
Box::pin(builder.execute_uncommitted()).await.unwrap();
}

MergeFixture {
Expand Down
2 changes: 1 addition & 1 deletion rust/lance/src/dataset/write.rs
Original file line number Diff line number Diff line change
Expand Up @@ -428,7 +428,7 @@ impl WriteParams {
/// IDs can be assigned after writing is complete.
#[deprecated(
since = "0.20.0",
note = "Use [`InsertBuilder::write_uncommitted_stream`] instead"
note = "Use [`InsertBuilder::execute_uncommitted_stream`] instead"
)]
pub async fn write_fragments(
dest: impl Into<WriteDestination<'_>>,
Expand Down
Loading