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

chore: Update influxql end to end tests to kafkaless write path (#6833) 

Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
pull/24376/head
Andrew Lamb 2023-02-03 15:11:55 +01:00 committed by GitHub
parent fc7f9323b4
commit acc258e9aa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
influxdb_iox/tests/end_to_end_cases/influxql.rs
View File

@ -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![