Runs `cleanup` queries to reset state after the benchmark run.
(&mut self, ctx: &SessionContext)
| 375 | |
| 376 | /// Runs `cleanup` queries to reset state after the benchmark run. |
| 377 | pub async fn cleanup(&mut self, ctx: &SessionContext) -> Result<()> { |
| 378 | info!("Running cleanup..."); |
| 379 | |
| 380 | let cleanup_queries = self.queries.get(&QueryDirective::Cleanup); |
| 381 | |
| 382 | if let Some(queries) = cleanup_queries { |
| 383 | for query in queries { |
| 384 | let _ = ctx.sql(query).await?.collect().await?; |
| 385 | } |
| 386 | } |
| 387 | |
| 388 | Ok(()) |
| 389 | } |
| 390 | |
| 391 | async fn load_expected_result_files(&mut self, ctx: &SessionContext) -> Result<()> { |
| 392 | for query in &mut self.result_queries { |
no test coverage detected