File tree Expand file tree Collapse file tree 1 file changed +9
-3
lines changed
datafusion/datasource/src Expand file tree Collapse file tree 1 file changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -259,17 +259,23 @@ impl ListingTableUrl {
259
259
Ok ( futures:: stream:: iter (
260
260
res. as_ref ( ) . clone ( ) . into_iter ( ) . map ( Ok ) ,
261
261
)
262
- . map ( |res| res. map_err ( |e| DataFusionError :: ObjectStore ( Box :: new ( e) ) ) )
262
+ . map ( |res| {
263
+ res. map_err ( |e| DataFusionError :: ObjectStore ( Box :: new ( e) ) )
264
+ } )
263
265
. boxed ( ) )
264
266
} else {
265
267
let vec = store
266
268
. list ( Some ( prefix) )
267
- . map ( |res| res. map_err ( |e| DataFusionError :: ObjectStore ( Box :: new ( e) ) ) )
269
+ . map ( |res| {
270
+ res. map_err ( |e| DataFusionError :: ObjectStore ( Box :: new ( e) ) )
271
+ } )
268
272
. try_collect :: < Vec < ObjectMeta > > ( )
269
273
. await ?;
270
274
cache. put ( prefix, Arc :: new ( vec. clone ( ) ) ) ;
271
275
Ok ( futures:: stream:: iter ( vec. into_iter ( ) . map ( Ok ) )
272
- . map ( |res| res. map_err ( |e| DataFusionError :: ObjectStore ( Box :: new ( e) ) ) )
276
+ . map ( |res| {
277
+ res. map_err ( |e| DataFusionError :: ObjectStore ( Box :: new ( e) ) )
278
+ } )
273
279
. boxed ( ) )
274
280
}
275
281
}
You can’t perform that action at this time.
0 commit comments