@@ -355,8 +355,7 @@ impl RawDeltaTable {
355
355
) ;
356
356
} ;
357
357
358
- rt ( ) . block_on ( cmd. into_future ( ) )
359
- . map_err ( PythonError :: from)
358
+ rt ( ) . block_on ( cmd. into_future ( ) ) . map_err ( PythonError :: from)
360
359
} ) ?;
361
360
self . _table . state = table. state ;
362
361
Ok ( metrics. files_deleted )
@@ -402,8 +401,7 @@ impl RawDeltaTable {
402
401
) ;
403
402
} ;
404
403
405
- rt ( ) . block_on ( cmd. into_future ( ) )
406
- . map_err ( PythonError :: from)
404
+ rt ( ) . block_on ( cmd. into_future ( ) ) . map_err ( PythonError :: from)
407
405
} ) ?;
408
406
self . _table . state = table. state ;
409
407
Ok ( serde_json:: to_string ( & metrics) . unwrap ( ) )
@@ -418,7 +416,6 @@ impl RawDeltaTable {
418
416
writer_properties=None ,
419
417
custom_metadata=None ,
420
418
) ) ]
421
-
422
419
#[ allow( clippy:: too_many_arguments) ]
423
420
pub fn compact_optimize (
424
421
& mut self ,
@@ -462,8 +459,7 @@ impl RawDeltaTable {
462
459
. map_err ( PythonError :: from) ?;
463
460
cmd = cmd. with_filters ( & converted_filters) ;
464
461
465
- rt ( ) . block_on ( cmd. into_future ( ) )
466
- . map_err ( PythonError :: from)
462
+ rt ( ) . block_on ( cmd. into_future ( ) ) . map_err ( PythonError :: from)
467
463
} ) ?;
468
464
self . _table . state = table. state ;
469
465
Ok ( serde_json:: to_string ( & metrics) . unwrap ( ) )
@@ -525,8 +521,7 @@ impl RawDeltaTable {
525
521
. map_err ( PythonError :: from) ?;
526
522
cmd = cmd. with_filters ( & converted_filters) ;
527
523
528
- rt ( ) . block_on ( cmd. into_future ( ) )
529
- . map_err ( PythonError :: from)
524
+ rt ( ) . block_on ( cmd. into_future ( ) ) . map_err ( PythonError :: from)
530
525
} ) ?;
531
526
self . _table . state = table. state ;
532
527
Ok ( serde_json:: to_string ( & metrics) . unwrap ( ) )
@@ -557,8 +552,7 @@ impl RawDeltaTable {
557
552
) ;
558
553
} ;
559
554
560
- rt ( ) . block_on ( cmd. into_future ( ) )
561
- . map_err ( PythonError :: from)
555
+ rt ( ) . block_on ( cmd. into_future ( ) ) . map_err ( PythonError :: from)
562
556
} ) ?;
563
557
self . _table . state = table. state ;
564
558
Ok ( ( ) )
@@ -588,8 +582,7 @@ impl RawDeltaTable {
588
582
) ;
589
583
} ;
590
584
591
- rt ( ) . block_on ( cmd. into_future ( ) )
592
- . map_err ( PythonError :: from)
585
+ rt ( ) . block_on ( cmd. into_future ( ) ) . map_err ( PythonError :: from)
593
586
} ) ?;
594
587
self . _table . state = table. state ;
595
588
Ok ( ( ) )
@@ -1221,8 +1214,7 @@ impl RawDeltaTable {
1221
1214
) ;
1222
1215
} ;
1223
1216
1224
- rt ( ) . block_on ( cmd. into_future ( ) )
1225
- . map_err ( PythonError :: from)
1217
+ rt ( ) . block_on ( cmd. into_future ( ) ) . map_err ( PythonError :: from)
1226
1218
} ) ?;
1227
1219
self . _table . state = table. state ;
1228
1220
Ok ( serde_json:: to_string ( & metrics) . unwrap ( ) )
0 commit comments