Skip to content

Commit 2a940bb

Browse files
committed
coordinator it: teardown keyspaces
1 parent a1e8c36 commit 2a940bb

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

scylla/tests/integration/statements/coordinator.rs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ use scylla::statement::batch::{Batch, BatchStatement, BatchType};
1616
use scylla::statement::Statement;
1717
use uuid::Uuid;
1818

19-
use crate::utils::{create_new_session_builder, setup_tracing, unique_keyspace_name};
19+
use crate::utils::{create_new_session_builder, setup_tracing, unique_keyspace_name, PerformDDL};
2020

2121
#[tokio::test]
2222
async fn test_enforce_request_coordinator() {
@@ -118,10 +118,10 @@ async fn test_enforce_non_existent_request_coordinator() {
118118
async fn test_exposed_request_coordinator() {
119119
setup_tracing();
120120
let session = create_new_session_builder().build().await.unwrap();
121+
let ks = unique_keyspace_name();
121122

122123
// Create schema for batches.
123124
{
124-
let ks = unique_keyspace_name();
125125
session
126126
.ddl(
127127
format!(
@@ -130,7 +130,7 @@ async fn test_exposed_request_coordinator() {
130130
)
131131
.await
132132
.unwrap();
133-
session.use_keyspace(ks, true).await.unwrap();
133+
session.use_keyspace(&ks, true).await.unwrap();
134134
session
135135
.ddl("CREATE TABLE IF NOT EXISTS test (a int PRIMARY KEY)")
136136
.await
@@ -242,4 +242,6 @@ async fn test_exposed_request_coordinator() {
242242
}
243243
}
244244
}
245+
246+
session.ddl(format!("DROP KEYSPACE {ks}")).await.unwrap();
245247
}

0 commit comments

Comments
 (0)