File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -287,21 +287,23 @@ impl DuckLakeTable {
287287 . object_store ( self . object_store_url . as_ref ( ) ) ?;
288288 let delete_object_path = ObjectPath :: from ( resolved_delete_path. as_str ( ) ) ;
289289 match object_store. head ( & delete_object_path) . await {
290- Ok ( _) => { } // file exists
291- Err ( object_store:: Error :: NotFound { .. } ) => {
290+ Ok ( _) => { } , // file exists
291+ Err ( object_store:: Error :: NotFound {
292+ ..
293+ } ) => {
292294 return Err ( DataFusionError :: Execution ( format ! (
293295 "Delete file referenced in catalog metadata is missing from storage: '{}'. \
294296 This indicates data corruption — deleted rows cannot be filtered out.",
295297 delete_file. path
296298 ) ) ) ;
297- }
299+ } ,
298300 Err ( e) => {
299301 return Err ( DataFusionError :: Execution ( format ! (
300302 "Failed to access delete file '{}': {}. \
301303 Without this file, deleted rows cannot be filtered.",
302304 delete_file. path, e
303305 ) ) ) ;
304- }
306+ } ,
305307 }
306308
307309 // Create PartitionedFile with footer size hint if available
Original file line number Diff line number Diff line change @@ -517,7 +517,10 @@ mod integration_tests {
517517 . await ?;
518518 let result = df. collect ( ) . await ;
519519
520- assert ! ( result. is_err( ) , "Query should fail when delete file is missing" ) ;
520+ assert ! (
521+ result. is_err( ) ,
522+ "Query should fail when delete file is missing"
523+ ) ;
521524 let err_msg = result. unwrap_err ( ) . to_string ( ) ;
522525 assert ! (
523526 err_msg. contains( "missing from storage" ) ,
You can’t perform that action at this time.
0 commit comments