Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: rename namespaces of differnet tests to avoid test failures

pull/24376/head
NGA-TRAN 2023-07-25 17:07:28 -04:00
parent 44e1c1abdb
commit e6cf9c9d61
2 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
influxdb_iox/tests/end_to_end_cases/cli.rs
View File

@ -335,7 +335,7 @@ async fn create_tables_negative() {
async {
// Need router grpc based address to create namespace
let router_grpc_addr = state.cluster().router().router_grpc_base().to_string();
let namespace = "ns_2";
let namespace = "ns_tablenegative";
println!("Create namespace {namespace}");
Command::cargo_bin("influxdb_iox")
@ -355,7 +355,7 @@ async fn create_tables_negative() {
async {
// Need router grpc based address to create tables
let router_grpc_addr = state.cluster().router().router_grpc_base().to_string();
let namespace = "ns_2";
let namespace = "ns_tablenegative";
// no partition tempplate specified
Command::cargo_bin("influxdb_iox")
@ -462,7 +462,7 @@ async fn create_tables_positive() {
async {
// Need router grpc based addres to create namespace
let router_grpc_addr = state.cluster().router().router_grpc_base().to_string();
let namespace = "ns_2";
let namespace = "ns_tablepositive";
println!("Create namespace {namespace}");
Command::cargo_bin("influxdb_iox")
@ -482,7 +482,7 @@ async fn create_tables_positive() {
async {
// Need router grpc based addres to create tables
let router_grpc_addr = state.cluster().router().router_grpc_base().to_string();
let namespace = "ns_2";
let namespace = "ns_tablepositive";
println!("Creating tables h2o_temperature, m0, cpu explicitly into {namespace}");
@ -558,7 +558,7 @@ async fn create_tables_write_and_query() {
let database_url = maybe_skip_integration!();
let mut cluster = MiniCluster::create_shared(database_url).await;
let namespace = "ns_2";
let namespace = "ns_createtables";
StepTest::new(
&mut cluster,
@ -568,7 +568,7 @@ async fn create_tables_write_and_query() {
async {
// Need router grpc based addres to create namespace
let router_grpc_addr = state.cluster().router().router_grpc_base().to_string();
let namespace = "ns_2";
let namespace = "ns_createtables";
println!("Create namespace {namespace}");
Command::cargo_bin("influxdb_iox")
@ -589,7 +589,7 @@ async fn create_tables_write_and_query() {
async {
// Need router grpc based addres to create tables
let router_grpc_addr = state.cluster().router().router_grpc_base().to_string();
let namespace = "ns_2";
let namespace = "ns_createtables";
println!("Creating tables h2o_temperature, m0, cpu explicitly into {namespace}");
@ -646,7 +646,7 @@ async fn create_tables_write_and_query() {
async {
// write must use router http based address
let router_http_addr = state.cluster().router().router_http_base().to_string();
let namespace = "ns_2";
let namespace = "ns_createtables";
println!("Writing into {namespace}");

2
influxdb_iox/tests/end_to_end_cases/table.rs
View File

@ -9,13 +9,11 @@ async fn create_tables() {
// Set up the cluster
let mut cluster = MiniCluster::create_shared(database_url).await;
// let mut namespace_name = "ns_1".to_string();
// Step to create namespace and its tables
let mut steps: Vec<_> = vec![Step::Custom(Box::new(move |state: &mut StepTestState| {
async move {
let namespace_name = state.cluster().namespace();
// let namespace_name = "ns_1";
let mut namespace_client = influxdb_iox_client::namespace::Client::new(
state.cluster().router().router_grpc_connection(),