diff --git a/ballista/core/src/cache_layer/object_store/file.rs b/ballista/core/src/cache_layer/object_store/file.rs index 860174dd1..f68e28c5a 100644 --- a/ballista/core/src/cache_layer/object_store/file.rs +++ b/ballista/core/src/cache_layer/object_store/file.rs @@ -88,11 +88,15 @@ where async fn put_opts( &self, - location: &Path, - bytes: Bytes, - opts: PutOptions, + _location: &Path, + _bytes: Bytes, + _opts: PutOptions, ) -> object_store::Result { - todo!() + Err(Error::NotSupported { + source: Box::new(BallistaError::General( + "Write path is not supported".to_string(), + )), + }) } async fn put_multipart( @@ -225,8 +229,9 @@ where fn list( &self, - prefix: Option<&Path>, + _prefix: Option<&Path>, ) -> BoxStream<'_, object_store::Result> { + // TODO we can no longer return an Err here // Err(Error::NotSupported { // source: Box::new(BallistaError::General("List is not supported".to_string())), // }) diff --git a/ballista/core/src/cache_layer/object_store/mod.rs b/ballista/core/src/cache_layer/object_store/mod.rs index 1570b2d77..6d754ecaf 100644 --- a/ballista/core/src/cache_layer/object_store/mod.rs +++ b/ballista/core/src/cache_layer/object_store/mod.rs @@ -71,11 +71,11 @@ impl ObjectStore for ObjectStoreWithKey { async fn put_opts( &self, - _location: &Path, - _bytes: Bytes, - _opts: PutOptions, + location: &Path, + bytes: Bytes, + opts: PutOptions, ) -> object_store::Result { - todo!() + self.inner.put_opts(location, bytes, opts).await } async fn put_multipart(