@@ -20,10 +20,12 @@ use datafusion::common::instant::Instant;
2020use datafusion:: common:: utils:: get_available_parallelism;
2121use datafusion:: common:: { DataFusionError , Result , exec_datafusion_err, exec_err} ;
2222use datafusion_sqllogictest:: {
23- CurrentlyExecutingSqlTracker , DataFusion , DataFusionSubstraitRoundTrip , Filter ,
24- TestContext , df_value_validator , read_dir_recursive , setup_scratch_dir ,
25- should_skip_file , should_skip_record , value_normalizer,
23+ CurrentlyExecutingSqlTracker , DataFusion , Filter , TestContext , df_value_validator ,
24+ read_dir_recursive , setup_scratch_dir , should_skip_file , should_skip_record ,
25+ value_normalizer,
2626} ;
27+ #[ cfg( feature = "substrait" ) ]
28+ use datafusion_sqllogictest:: DataFusionSubstraitRoundTrip ;
2729use futures:: stream:: StreamExt ;
2830use indicatif:: {
2931 HumanDuration , MultiProgress , ProgressBar , ProgressDrawTarget , ProgressStyle ,
@@ -287,6 +289,7 @@ async fn run_tests() -> Result<()> {
287289 }
288290}
289291
292+ #[ cfg( feature = "substrait" ) ]
290293async fn run_test_file_substrait_round_trip (
291294 test_file : TestFile ,
292295 validator : Validator ,
@@ -328,6 +331,19 @@ async fn run_test_file_substrait_round_trip(
328331 res
329332}
330333
334+ #[ cfg( not( feature = "substrait" ) ) ]
335+ async fn run_test_file_substrait_round_trip (
336+ _test_file : TestFile ,
337+ _validator : Validator ,
338+ _mp : MultiProgress ,
339+ _mp_style : ProgressStyle ,
340+ _filters : & [ Filter ] ,
341+ _currently_executing_sql_tracker : CurrentlyExecutingSqlTracker ,
342+ ) -> Result < ( ) > {
343+ use datafusion:: common:: plan_err;
344+ plan_err ! ( "Can not run substrait round-trip as the substrait feature is not enabled" )
345+ }
346+
331347async fn run_test_file (
332348 test_file : TestFile ,
333349 validator : Validator ,
0 commit comments