We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5c05fad commit 483d5d5Copy full SHA for 483d5d5
1 file changed
catalogs/iceberg-rest-catalog/src/catalog.rs
@@ -293,17 +293,17 @@ impl Catalog for RestCatalog {
293
.await
294
.map_err(|_| Error::CatalogNotFound)?;
295
296
- let object_store = object_store_from_response(&response)
+ let object_store = object_store_from_response(&response)?
297
+ .ok_or(Error::NotFound("Object store credentials".to_string()))
298
.or_else(|_| {
299
self.default_object_store_builder
300
.as_ref()
- .map(|x| {
301
+ .ok_or(Error::NotFound("Default object store".to_string()))
302
+ .and_then(|x| {
303
let bucket = Bucket::from_path(&response.metadata.location)?;
304
x.build(bucket)
305
})
- .transpose()
- })?
306
- .ok_or(Error::NotFound("Object store credentials".to_string()))?;
+ })?;
307
308
self.cache
309
.write()
0 commit comments