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

test: use proper ignore instead of commenting out

pull/24376/head
Marco Neumann 2021-08-12 11:38:02 +02:00
parent a5c74f2798
commit a72bacae67
1 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
write_buffer/src/config.rs
View File

@ -155,23 +155,28 @@ mod tests {
}
}
// blocks until https://github.com/influxdata/influxdb_iox/issues/2189 is solved
// #[tokio::test]
// async fn test_reading_kafka() {
// let factory = WriteBufferConfigFactory::new();
#[tokio::test]
#[ignore = "waits forever to connect until https://github.com/influxdata/influxdb_iox/issues/2189 is solved"]
async fn test_reading_kafka() {
let factory = WriteBufferConfigFactory::new();
// let server_id = ServerId::try_from(1).unwrap();
let server_id = ServerId::try_from(1).unwrap();
// let mut rules = DatabaseRules::new(DatabaseName::new("foo").unwrap());
// rules.write_buffer_connection = Some(WriteBufferConnection::Reading("test".to_string()));
let mut rules = DatabaseRules::new(DatabaseName::new("foo").unwrap());
rules.write_buffer_connection = Some(WriteBufferConnection::Reading("test".to_string()));
// if let WriteBufferConfig::Reading(conn) = factory.new_config(server_id, &rules).await.unwrap().unwrap() {
// let conn = conn.lock().await;
// assert_eq!(conn.type_name(), "kafka");
// } else {
// panic!("not a reading connection");
// }
// }
if let WriteBufferConfig::Reading(conn) = factory
.new_config(server_id, &rules)
.await
.unwrap()
.unwrap()
{
let conn = conn.lock().await;
assert_eq!(conn.type_name(), "kafka");
} else {
panic!("not a reading connection");
}
}
#[tokio::test]
async fn test_writing_mock() {