From acc258e9aa871b4c6e5d37619e5cc5229216cff3 Mon Sep 17 00:00:00 2001 From: Andrew Lamb Date: Fri, 3 Feb 2023 15:11:55 +0100 Subject: [PATCH] chore: Update influxql end to end tests to kafkaless write path (#6833) Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com> --- influxdb_iox/tests/end_to_end_cases/influxql.rs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/influxdb_iox/tests/end_to_end_cases/influxql.rs b/influxdb_iox/tests/end_to_end_cases/influxql.rs index 602e3c4c9a..6b970483fe 100644 --- a/influxdb_iox/tests/end_to_end_cases/influxql.rs +++ b/influxdb_iox/tests/end_to_end_cases/influxql.rs @@ -8,7 +8,7 @@ async fn influxql_returns_error() { let table_name = "the_table"; // Set up the cluster ==================================== - let mut cluster = MiniCluster::create_shared(database_url).await; + let mut cluster = MiniCluster::create_shared2(database_url).await; StepTest::new( &mut cluster, @@ -18,7 +18,6 @@ async fn influxql_returns_error() { {},tag1=A,tag2=C val=43i 123457", table_name, table_name )), - Step::WaitForReadable, Step::InfluxQLExpectingError { query: "SHOW TAG KEYS".into(), expected_error_code: tonic::Code::InvalidArgument, @@ -40,7 +39,7 @@ async fn influxql_select_returns_results() { let table_name = "the_table"; // Set up the cluster ==================================== - let mut cluster = MiniCluster::create_shared(database_url).await; + let mut cluster = MiniCluster::create_shared2(database_url).await; StepTest::new( &mut cluster, @@ -50,7 +49,6 @@ async fn influxql_select_returns_results() { {},tag1=A,tag2=C val=43i 123457", table_name, table_name )), - Step::WaitForReadable, Step::InfluxQLQuery { query: format!("select tag1, val from {}", table_name), expected: vec![