Method assert

benchmarks/src/sql_benchmark.rs:167–186

Executes the `assert` queries and compares actual results against expected values. Each `assert` query must be followed by a result table (separated by `----`) in the benchmark file. The assertion passes only if the returned record batches exactly match the expected rows. # Errors Returns an error if any `assert` query fails, or if the actual and expected results differ in row count or cell val

(&mut self, ctx: &SessionContext)

    /// Returns an error if any `assert` query fails, or if the actual and
    /// expected results differ in row count or cell values.
    pub async fn assert(&mut self, ctx: &SessionContext) -> Result<()> {
        info!("Running assertions...");

        for assert_query in &self.assert_queries {
            let query = &assert_query.query;

            info!("Executing assert query {query}");

            let result = ctx.sql(query).await?.collect().await?;
            let formatted_actual_results = format_record_batches(&result)?;

            Self::compare_results(
                assert_query,
                &formatted_actual_results,
                &assert_query.expected_result,
            )?;
        }

        Ok(())
    }

    /// Executes the `run` queries, optionally saving results for later
    /// verification. If there are multiple queries only the results for