rust/lancedb
1
0
Fork 0
mirror of https://github.com/lancedb/lancedb.git synced 2026-05-14 10:30:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: add storage_options to object_store wrap()

Browse Source 
Adds storage_options to object_store wrap() to adhere to upstream lance
change.
This commit is contained in:
Wyatt Alt
2025-08-18 05:49:06 -07:00
committed by Wyatt Alt
parent f6846004ca
commit 140a4e2f53
3 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
rust/lancedb/src/io/object_store.rs
View File

@@ -170,7 +170,11 @@ impl MirroringObjectStoreWrapper {
}
impl WrappingObjectStore for MirroringObjectStoreWrapper {
fn wrap(&self, primary: Arc<dyn ObjectStore>) -> Arc<dyn ObjectStore> {
fn wrap(
&self,
primary: Arc<dyn ObjectStore>,
_storage_options: Option<&std::collections::HashMap<String, String>>,
) -> Arc<dyn ObjectStore> {
Arc::new(MirroringObjectStore {
primary,
secondary: self.secondary.clone(),

6
rust/lancedb/src/io/object_store/io_tracking.rs
View File

@@ -50,7 +50,11 @@ impl IoStatsHolder {
}
impl WrappingObjectStore for IoStatsHolder {
fn wrap(&self, target: Arc<dyn ObjectStore>) -> Arc<dyn ObjectStore> {
fn wrap(
&self,
target: Arc<dyn ObjectStore>,
_storage_options: Option<&std::collections::HashMap<String, String>>,
) -> Arc<dyn ObjectStore> {
Arc::new(IoTrackingStore {
target,
stats: self.0.clone(),

1
rust/lancedb/src/table.rs
View File

@@ -3264,6 +3264,7 @@ mod tests {
fn wrap(
&self,
original: Arc<dyn object_store::ObjectStore>,
_storage_options: Option<&std::collections::HashMap<String, String>>,
) -> Arc<dyn object_store::ObjectStore> {
self.called.store(true, Ordering::Relaxed);
original