diff --git a/Cargo.lock b/Cargo.lock index 729a53f..08e54fe 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1402,7 +1402,7 @@ dependencies = [ [[package]] name = "object_store_ffi" -version = "0.12.0" +version = "0.12.1" dependencies = [ "anyhow", "async-channel", diff --git a/Cargo.toml b/Cargo.toml index ecbd3e9..cfa5ede 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "object_store_ffi" -version = "0.12.0" +version = "0.12.1" edition = "2021" [[bench]] diff --git a/src/crud_ops.rs b/src/crud_ops.rs index 4ea4c97..85eb2ae 100644 --- a/src/crud_ops.rs +++ b/src/crud_ops.rs @@ -229,6 +229,8 @@ impl Client { } async fn bulk_delete_impl(&self, paths: &Vec) -> crate::Result> { + // Add the client prefix to the provided paths if needed + let paths = paths.into_iter().map(|path| self.full_path(path)).collect::>(); let stream = stream::iter(paths.iter().map(|path| Ok(path.clone()))).boxed(); let results = self.store.delete_stream(stream) .collect::>().await;