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 @@ -3195,11 +3195,13 @@ fn roundtrip_dynamic_filter_plan_pair() -> Result<(
31953195 . expect ( "Expected outer FilterExec" ) ;
31963196 let left_filter = Arc :: clone ( outer_filter. predicate ( ) ) ;
31973197 let projection = outer_filter. children ( ) [ 0 ]
3198+ . as_ref ( )
31983199 . as_any ( )
31993200 . downcast_ref :: < ProjectionExec > ( )
32003201 . expect ( "Expected ProjectionExec" ) ;
32013202 let data_source = projection
32023203 . input ( )
3204+ . as_ref ( )
32033205 . as_any ( )
32043206 . downcast_ref :: < DataSourceExec > ( )
32053207 . expect ( "Expected DataSourceExec" ) ;
@@ -3295,7 +3297,10 @@ fn test_dynamic_filter_roundtrip_dedupe_shallow() -> Result<()> {
32953297 roundtrip_dynamic_filter_expr_pair ( filter_expr_1, filter_expr_2, schema) ?;
32963298
32973299 assert_dynamic_filter_snapshot_matches ( & filter_1_before_roundtrip, & left_filter) ;
3298- assert_dynamic_filter_snapshot_matches ( & filter_2_before_roundtrip_expr, & right_filter) ;
3300+ assert_dynamic_filter_snapshot_matches (
3301+ & filter_2_before_roundtrip_expr,
3302+ & right_filter,
3303+ ) ;
32993304
33003305 assert_dynamic_filter_update_is_visible ( & left_filter, & right_filter) ?;
33013306
You can’t perform that action at this time.
0 commit comments