File tree Expand file tree Collapse file tree
datafusion/proto/tests/cases Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -3205,11 +3205,13 @@ fn roundtrip_dynamic_filter_plan_pair() -> Result<(
32053205 . expect ( "Expected outer FilterExec" ) ;
32063206 let left_filter = Arc :: clone ( outer_filter. predicate ( ) ) ;
32073207 let projection = outer_filter. children ( ) [ 0 ]
3208+ . as_ref ( )
32083209 . as_any ( )
32093210 . downcast_ref :: < ProjectionExec > ( )
32103211 . expect ( "Expected ProjectionExec" ) ;
32113212 let data_source = projection
32123213 . input ( )
3214+ . as_ref ( )
32133215 . as_any ( )
32143216 . downcast_ref :: < DataSourceExec > ( )
32153217 . expect ( "Expected DataSourceExec" ) ;
@@ -3305,7 +3307,10 @@ fn test_dynamic_filter_roundtrip_dedupe_shallow() -> Result<()> {
33053307 roundtrip_dynamic_filter_expr_pair ( filter_expr_1, filter_expr_2, schema) ?;
33063308
33073309 assert_dynamic_filter_snapshot_matches ( & filter_1_before_roundtrip, & left_filter) ;
3308- assert_dynamic_filter_snapshot_matches ( & filter_2_before_roundtrip_expr, & right_filter) ;
3310+ assert_dynamic_filter_snapshot_matches (
3311+ & filter_2_before_roundtrip_expr,
3312+ & right_filter,
3313+ ) ;
33093314
33103315 assert_dynamic_filter_update_is_visible ( & left_filter, & right_filter) ?;
33113316
You can’t perform that action at this time.
0 commit comments