@@ -20,7 +20,7 @@ use anyhow::{bail, Result};
20
20
use itertools:: Itertools ;
21
21
use rand:: { thread_rng, Rng , SeedableRng } ;
22
22
use rand_chacha:: ChaChaRng ;
23
- use sqllogictest:: { ParallelTestError , Record } ;
23
+ use sqllogictest:: { ParallelTestError , QueryExpect , Record , StatementExpect } ;
24
24
25
25
use crate :: client:: RisingWave ;
26
26
use crate :: cluster:: { Cluster , KillOpts } ;
@@ -275,9 +275,8 @@ pub async fn run_slt_task(
275
275
loc : loc. clone ( ) ,
276
276
conditions : conditions. clone ( ) ,
277
277
connection : connection. clone ( ) ,
278
- expected_error : None ,
278
+ expected : StatementExpect :: Ok ,
279
279
sql : format ! ( "SET BACKGROUND_DDL={background_ddl_setting};" ) ,
280
- expected_count : None ,
281
280
} ;
282
281
tester. run_async ( set_background_ddl) . await . unwrap ( ) ;
283
282
background_ddl_enabled = background_ddl_setting;
@@ -344,13 +343,13 @@ pub async fn run_slt_task(
344
343
// For background ddl
345
344
if let SqlCmd :: CreateMaterializedView { ref name } = cmd
346
345
&& background_ddl_enabled
347
- && matches ! (
346
+ && ! matches ! (
348
347
record,
349
348
Record :: Statement {
350
- expected_error : None ,
349
+ expected : StatementExpect :: Error ( _ ) ,
351
350
..
352
351
} | Record :: Query {
353
- expected_error : None ,
352
+ expected : QueryExpect :: Error ( _ ) ,
354
353
..
355
354
}
356
355
)
0 commit comments