From e365693497e7055ee891748621ee3472efc6047a Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Tue, 23 Jan 2024 21:08:35 +0100 Subject: [PATCH] fix: remove first part of account_identifier for snowflake --- backend/windmill-worker/src/snowflake_executor.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/backend/windmill-worker/src/snowflake_executor.rs b/backend/windmill-worker/src/snowflake_executor.rs index d898343e2d..df084fddcb 100644 --- a/backend/windmill-worker/src/snowflake_executor.rs +++ b/backend/windmill-worker/src/snowflake_executor.rs @@ -73,8 +73,12 @@ pub async fn do_snowflake( ) .map_err(|e| Error::ExecutionErr(e.to_string()))?; - let qualified_username = - format!("{}.{}", database.account_identifier, database.username).to_uppercase(); + let qualified_username = format!( + "{}.{}", + database.account_identifier.split('.').next().unwrap_or(""), // get first part of account identifier + database.username + ) + .to_uppercase(); let public_key = pem::parse(database.public_key.as_bytes()).map_err(|e| { Error::ExecutionErr(format!("Failed to parse public key: {}", e.to_string()))