File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -608,25 +608,34 @@ async fn test_output_parquet() {
608608
609609 let cloned_path = path. clone ( ) ;
610610
611- let sql = "SELECT 1" . to_string ( ) ;
612- Command :: cargo_bin ( "dft" )
613- . unwrap ( )
614- . arg ( "-c" )
615- . arg ( sql. clone ( ) )
616- . arg ( "--flightsql" )
617- . arg ( "-o" )
618- . arg ( cloned_path)
619- . assert ( )
620- . success ( ) ;
611+ tokio:: task:: spawn_blocking ( || {
612+ let sql = "SELECT 1" . to_string ( ) ;
613+ Command :: cargo_bin ( "dft" )
614+ . unwrap ( )
615+ . arg ( "-c" )
616+ . arg ( sql. clone ( ) )
617+ . arg ( "--flightsql" )
618+ . arg ( "-o" )
619+ . arg ( cloned_path)
620+ . timeout ( Duration :: from_secs ( 5 ) )
621+ . assert ( )
622+ . success ( ) ;
623+ } )
624+ . await
625+ . unwrap ( ) ;
621626
622627 let read_sql = format ! ( "SELECT * FROM '{}'" , path. to_str( ) . unwrap( ) ) ;
623628
624- let assert = Command :: cargo_bin ( "dft" )
625- . unwrap ( )
626- . arg ( "-c" )
627- . arg ( read_sql)
628- . assert ( )
629- . success ( ) ;
629+ let assert = tokio:: task:: spawn_blocking ( || {
630+ Command :: cargo_bin ( "dft" )
631+ . unwrap ( )
632+ . arg ( "-c" )
633+ . arg ( read_sql)
634+ . assert ( )
635+ . success ( )
636+ } )
637+ . await
638+ . unwrap ( ) ;
630639
631640 let expected = r#"
632641+----------+
You can’t perform that action at this time.
0 commit comments