Make the test work again
(yes, this was messed up because of a cherry pick that had to be
performed in order to get a working PR)
@@ -77,10 +77,16 @@ async fn simple_insertion() -> Result<()> {
"host": DB_HOST,
"port": port,
"database": "",
+ "columns": [
+ {
+ "name": "age",
+ "type": "UInt8",
+ }
+ ]
},
});
- let harness = ConnectorHarness::new("clickhouse", &connector_config).await?;
+ let harness = ConnectorHarness::new(function_name!(), "clickhouse", &connector_config).await?;
let in_pipe = harness.get_pipe(IN).expect("No pipe connected to port IN");
