@@ -202,13 +202,9 @@ async fn main() -> Result<()> {
202202
203203 match ( & duckdb_result, & datafusion_result) {
204204 ( Ok ( duck) , Ok ( df) ) => {
205- if let Err ( e) = assert_results_match (
206- & query. name ,
207- duck,
208- "DuckDB" ,
209- df,
210- "DataFusion" ,
211- ) {
205+ if let Err ( e) =
206+ assert_results_match ( & query. name , duck, "DuckDB" , df, "DataFusion" )
207+ {
212208 if args. skip_errors {
213209 println ! ( "SKIP (row mismatch)" ) ;
214210 skipped_queries. push ( ( query. name . clone ( ) , e. to_string ( ) ) ) ;
@@ -218,23 +214,28 @@ async fn main() -> Result<()> {
218214 } else {
219215 println ! ( "done ({} rows)" , duck. row_count) ;
220216 }
221- }
217+ } ,
222218 ( Err ( e) , _) => {
223219 if args. skip_errors {
224220 println ! ( "SKIP (DuckDB error)" ) ;
225221 skipped_queries. push ( ( query. name . clone ( ) , format ! ( "DuckDB: {}" , e) ) ) ;
226222 } else {
227223 return Err ( anyhow:: anyhow!( "DuckDB failed on {}: {}" , query. name, e) ) ;
228224 }
229- }
225+ } ,
230226 ( _, Err ( e) ) => {
231227 if args. skip_errors {
232228 println ! ( "SKIP (DataFusion error)" ) ;
233- skipped_queries. push ( ( query. name . clone ( ) , format ! ( "DataFusion: {}" , e) ) ) ;
229+ skipped_queries
230+ . push ( ( query. name . clone ( ) , format ! ( "DataFusion: {}" , e) ) ) ;
234231 } else {
235- return Err ( anyhow:: anyhow!( "DataFusion failed on {}: {}" , query. name, e) ) ;
232+ return Err ( anyhow:: anyhow!(
233+ "DataFusion failed on {}: {}" ,
234+ query. name,
235+ e
236+ ) ) ;
236237 }
237- }
238+ } ,
238239 }
239240 }
240241 if !skipped_queries. is_empty ( ) {
0 commit comments