diff --git a/crates/backend/Cargo.toml b/crates/backend/Cargo.toml index a477847c..f72ecff7 100644 --- a/crates/backend/Cargo.toml +++ b/crates/backend/Cargo.toml @@ -88,11 +88,11 @@ tokio = { version = "1.36.0", optional = true, default-features = false } [target.'cfg(not(windows))'.dependencies] # opendal backend - sftp is not supported on windows, see https://github.com/apache/incubator-opendal/issues/2963 -opendal = { version = "0.45", features = ["services-b2", "services-sftp", "services-swift", "layers-blocking", "layers-throttle"], optional = true } +opendal = { version = "0.46", features = ["services-b2", "services-sftp", "services-swift", "services-azblob", "services-azdls", "services-cos", "services-fs", "services-gcs", "services-ghac", "services-http", "services-ipmfs", "services-memory", "services-obs", "services-oss", "services-s3", "services-webdav", "services-webhdfs", "services-azfile", "layers-blocking", "layers-throttle"], optional = true } [target.'cfg(windows)'.dependencies] # opendal backend -opendal = { version = "0.45", features = ["services-b2", "services-swift", "layers-blocking", "layers-throttle"], optional = true } +opendal = { version = "0.46", features = ["services-b2", "services-swift", "services-azblob", "services-azdls", "services-cos", "services-fs", "services-gcs", "services-ghac", "services-http", "services-ipmfs", "services-memory", "services-obs", "services-oss", "services-s3", "services-webdav", "services-webhdfs", "services-azfile", "layers-blocking", "layers-throttle"], optional = true } [dev-dependencies] rstest = { workspace = true } diff --git a/crates/backend/src/opendal.rs b/crates/backend/src/opendal.rs index 89b811ed..73ef91b8 100644 --- a/crates/backend/src/opendal.rs +++ b/crates/backend/src/opendal.rs @@ -213,7 +213,7 @@ impl ReadBackend for OpenDALBackend { fn read_full(&self, tpe: FileType, id: &Id) -> Result { trace!("reading tpe: {tpe:?}, id: {id}"); - Ok(self.operator.read(&self.path(tpe, id))?.into()) + Ok(self.operator.read(&self.path(tpe, id))?.to_bytes()) } fn read_partial( @@ -231,7 +231,7 @@ impl ReadBackend for OpenDALBackend { .read_with(&self.path(tpe, id)) .range(range) .call()? - .into()) + .to_bytes()) } }