From ba9f7927bee614a7855448b5d014ec32a93e0752 Mon Sep 17 00:00:00 2001 From: Andy Grove Date: Mon, 11 Dec 2023 12:13:29 -0700 Subject: [PATCH] address another todo item --- .../core/src/cache_layer/object_store/file.rs | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/ballista/core/src/cache_layer/object_store/file.rs b/ballista/core/src/cache_layer/object_store/file.rs index f68e28c5a..169d2b5ce 100644 --- a/ballista/core/src/cache_layer/object_store/file.rs +++ b/ballista/core/src/cache_layer/object_store/file.rs @@ -22,7 +22,7 @@ use crate::error::BallistaError; use async_trait::async_trait; use ballista_cache::loading_cache::LoadingCache; use bytes::Bytes; -use futures::stream::BoxStream; +use futures::stream::{self, BoxStream, StreamExt}; use log::info; use object_store::path::Path; use object_store::{ @@ -231,11 +231,14 @@ where &self, _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())), - // }) - todo!() + stream::once(async { + Err(Error::NotSupported { + source: Box::new(BallistaError::General( + "List is not supported".to_string(), + )), + }) + }) + .boxed() } async fn list_with_delimiter(