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

refactor: fix lint failures

pull/24376/head
Dom Dwyer 2023-04-27 13:06:12 +02:00
parent 70420d1c47
commit c76129a7e8
No known key found for this signature in database
GPG Key ID: E4C40DBD9157879A
2 changed files with 0 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -301,9 +301,6 @@ async fn flightsql_get_catalogs_matches_information_schema() {
// output of get_catalogs is built manually in
// IOx, so it is important it remains in sync with
// the actual contents of the information schema
fn no_filter() -> Option<String> {
None
}
let stream = client
.get_catalogs()
.await
@ -780,9 +777,6 @@ async fn flightsql_get_table_types_matches_information_schema() {
// output of get_table_types is built manually in
// IOx, so it is important it remains in sync with
// the actual contents of the information schema
fn no_filter() -> Option<String> {
None
}
let stream = client
.get_table_types()
.await

4
router/src/dml_handlers/rpc_write/balancer.rs
View File

@ -222,8 +222,6 @@ mod tests {
/// No healthy nodes prevents a snapshot from being returned.
#[tokio::test]
async fn test_balancer_empty_iter() {
const BALANCER_CALLS: usize = 10;
// Initialise 3 RPC clients and configure their mock circuit breakers;
// all are unhealthy and should not be probed.
let circuit_err_1 = Arc::new(MockCircuitBreaker::default());
@ -380,8 +378,6 @@ mod tests {
/// An unhealthy node that recovers is yielded to the caller.
#[tokio::test]
async fn test_balancer_upstream_recovery() {
const BALANCER_CALLS: usize = 10;
// Initialise a single client and configure its mock circuit breaker to
// return unhealthy.
let circuit = Arc::new(MockCircuitBreaker::default());