Skip to content

Commit

Permalink
fix Format
Browse files Browse the repository at this point in the history
  • Loading branch information
mediuminvader committed Jan 27, 2023
1 parent 7d974f8 commit 57279c6
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
5 changes: 2 additions & 3 deletions dozer-ingestion/src/connectors/snowflake/connection/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -254,9 +254,8 @@ impl Client {
conn: &Connection<AutocommitOn>,
table_name: &String,
) -> Result<bool, SnowflakeError> {
let query = format!(
"SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '{table_name}';"
);
let query =
format!("SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '{table_name}';");

let stmt = Statement::with_parent(conn).map_err(|e| QueryError(Box::new(e)))?;
stmt.exec_direct(&query)
Expand Down
4 changes: 1 addition & 3 deletions dozer-ingestion/src/connectors/snowflake/tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -79,9 +79,7 @@ fn connector_disabled_test_e2e_connect_snowflake_schema_changes_test() {
client
.execute_query(
&conn,
&format!(
"CREATE TABLE {table_name} LIKE SNOWFLAKE_SAMPLE_DATA.TPCH_SF1.NATION;"
),
&format!("CREATE TABLE {table_name} LIKE SNOWFLAKE_SAMPLE_DATA.TPCH_SF1.NATION;"),
)
.unwrap();
client
Expand Down

0 comments on commit 57279c6

Please sign in to comment.