Merge pull request #25 from timvw/fix-delta

fix: discovery of delta tables

src/globbing_table.rs

@@ -45,6 +45,7 @@ async fn load_listing_table(
     globbing_path: &GlobbingPath,
 ) -> Result<ListingTable> {
     let matching_file_urls = list_matching_table_urls(ctx, globbing_path).await?;
+    assert!(!matching_file_urls.is_empty());
     let mut config = ListingTableConfig::new_with_multi_paths(matching_file_urls);
     config = config.infer_options(&ctx.state()).await?;
     config = config.infer_schema(&ctx.state()).await?;

src/object_store_util.rs

@@ -69,9 +69,11 @@ pub async fn list_matching_files<P>(
 where
     P: FnMut(&ObjectMeta) -> bool,
 {
-    let items: Vec<ObjectMeta> = match store.head(prefix).await {
-        Ok(meta) => vec![meta],
-        Err(_) => store.list(Some(prefix)).await?.try_collect().await?,
+    let items: Vec<ObjectMeta> = store.list(Some(prefix)).await?.try_collect().await?;
+    let items = if items.is_empty() {
+        vec![store.head(prefix).await?]
+    } else {
+        items
     };
     let filtered_items = items.into_iter().filter(predicate).collect();
     Ok(filtered_items)