Method verify

benchmarks/src/sql_benchmark.rs:344–374

Verifies persisted results against expected values. Executes the `result_query` or uses the stored last run results, then compares actual output rows to the expected values defined in the benchmark file. # Errors Returns an error if no results are available or if the actual and expected results differ in count or content.

(&mut self, ctx: &SessionContext)

    /// Returns an error if no results are available or if the actual and
    /// expected results differ in count or content.
    pub async fn verify(&mut self, ctx: &SessionContext) -> Result<()> {
        // Check if we have result queries to verify
        if self.result_queries.is_empty() {
            return Ok(());
        }

        if self.last_results.is_none() {
            return Err(exec_datafusion_err!(
                "No results available for verification. Run the benchmark first."
            ));
        }

        info!("Verifying results...");

        self.load_expected_result_files(ctx).await?;

        // Get the first result query (assuming only one for now)
        let query = &self.result_queries[0];
        let formatted_actual_results = if !query.query.trim().is_empty() {
            let results = ctx.sql(&query.query).await?.collect().await?;
            format_record_batches(&results)
        } else {
            let actual_results = self
                .last_results
                .as_ref()
                .expect("last_results should be present after successful run");
            format_record_batches(actual_results)
        }?;

        Self::compare_results(query, &formatted_actual_results, &query.expected_result)
    }

    /// Runs `cleanup` queries to reset state after the benchmark run.
    pub async fn cleanup(&mut self, ctx: &SessionContext) -> Result<()> {