Function cleanup_propagates_query_failures

benchmarks/src/sql_benchmark.rs:2897–2915

()

    #[tokio::test]
    async fn cleanup_propagates_query_failures() {
        let mut benchmark = parse_benchmark(
            r#"
run
SELECT 1;

cleanup
SELECT * FROM missing_cleanup_table;
"#,
        )
        .await
        .expect("benchmark should parse");
        let ctx = SessionContext::new();

        assert_result_error_contains(
            benchmark.cleanup(&ctx).await,
            "missing_cleanup_table",
        );
    }

    #[tokio::test]
    async fn assert_executes_assert_queries_successfully() {