@@ -325,32 +325,23 @@ impl StatementExecutor {
325325 let adjusted = AdjustedPrintOptions :: new ( print_options. clone ( ) )
326326 . with_statement ( & self . statement ) ;
327327
328- let plan = create_plan ( ctx, self . statement . clone ( ) , false ) . await ?;
328+ let plan = create_plan ( ctx, self . statement , false ) . await ?;
329329 let adjusted = adjusted. with_plan ( & plan) ;
330330
331331 let df = match ctx. execute_logical_plan ( plan) . await {
332- Ok ( df) => df ,
332+ Ok ( df) => Ok ( df ) ,
333333 Err ( DataFusionError :: ObjectStore ( err) )
334- if matches ! ( err. as_ref( ) , object_store :: Error :: Generic { store, source: _ } if "S3" . eq_ignore_ascii_case( store) )
334+ if matches ! ( err. as_ref( ) , Generic { store, source: _ } if "S3" . eq_ignore_ascii_case( store) )
335335 && self . statement_for_retry . is_some ( ) =>
336336 {
337- {
338- let Generic {
339- store : _,
340- source : _,
341- } = err. as_ref ( )
342- else {
343- unreachable ! ( )
344- } ;
345- warn ! ( "S3 region is incorrect, auto-detecting the correct region (this may be slow). Consider updating your region configuration." ) ;
346- let plan =
347- create_plan ( ctx, self . statement_for_retry . take ( ) . unwrap ( ) , true )
348- . await ?;
349- ctx. execute_logical_plan ( plan) . await
350- } ?
337+ warn ! ( "S3 region is incorrect, auto-detecting the correct region (this may be slow). Consider updating your region configuration." ) ;
338+ let plan =
339+ create_plan ( ctx, self . statement_for_retry . take ( ) . unwrap ( ) , true )
340+ . await ?;
341+ ctx. execute_logical_plan ( plan) . await
351342 }
352- Err ( e) => return Err ( e) ,
353- } ;
343+ Err ( e) => Err ( e) ,
344+ } ? ;
354345
355346 Ok ( ( df, adjusted) )
356347 }
0 commit comments