You are an expert in writing code in many different languages. Your goal is to perform code completion for the following code, keeping in mind the rest of the code and the file meta data.
    Metadata details:
    filename: create_sf.rs
    path of file: ./repos/peerdb/nexus/server/tests/create_peers
    
    the code of the file until where you have to start completion: use pt::peerdb_peers::SnowflakeConfig;

use postgres::Client;
use std::env;
use std::fs::File;
use std::io::Read;

pub fn create(nexus: &mut Client) {
    dotenvy::dotenv().ok();
    let config_file_path = env::var("TEST_SF_CREDS").expect("TEST_SF_CREDS not set");
    let mut file = File::open(config_file_path).expect("failed to open snowflake json");
    let mut contents = String::new();
    file.read_to_string(&mut contents)
        .expect("failed to read snowflake json");

    let sf_config: SnowflakeConfig =
        serde_json::from_str(&contents).expect("failed to parse snowflake json");

    let create_stmt = format!(
        "
    CREATE PEER IF NOT EXISTS sf_
    
pub fn create(nexus: &mut Client) {
    dotenvy::dotenv().ok();
    let config_file_path = env::var("TEST_SF_CREDS").expect("TEST_SF_CREDS not set");
    let mut file = File::open(config_file_path).expect("failed to open snowflake json");
    let mut contents = String::new();
    file.read_to_string(&mut contents)
        .expect("failed to read snowflake json");

    let sf_config: SnowflakeConfig =
        serde_json::from_str(&contents).expect("failed to parse snowflake json");

    let create_stmt = format!(
        "
    CREATE PEER IF NOT EXISTS sf_test FROM SNOWFLAKE WITH
        (
        account_id = '{}',
        username = '{}',
        private_key = '{}',
        database = '{}',
        warehouse = '{}',
        role = '{}',
        query_timeout = '{}',
        s3_integration = '{}'
        );",
        &sf_config.account_id,
        &sf_config.username,
        &sf_config.private_key,
        "SNOWFLAKE_CI",
        &sf_config.warehouse,
        &sf_config.role,
        &sf_config.query_timeout,
        &sf_config.s3_integration
    );

    let _ = nexus.simple_query(&create_stmt);
}