| 389 | } |
| 390 | |
| 391 | async fn load_expected_result_files(&mut self, ctx: &SessionContext) -> Result<()> { |
| 392 | for query in &mut self.result_queries { |
| 393 | if query.query.trim().is_empty() { |
| 394 | let Some(path) = query.path.clone() else { |
| 395 | continue; |
| 396 | }; |
| 397 | |
| 398 | let loaded_query = |
| 399 | read_query_from_file(ctx, path, &HashMap::new()).await?; |
| 400 | query.column_count = loaded_query.column_count; |
| 401 | query.expected_result = loaded_query.expected_result; |
| 402 | } |
| 403 | } |
| 404 | |
| 405 | Ok(()) |
| 406 | } |
| 407 | |
| 408 | fn compare_results( |
| 409 | query: &BenchmarkQuery, |