From 5fbe61d28d0918afad7bdbf23bc3e812b77dc369 Mon Sep 17 00:00:00 2001 From: Dave Date: Wed, 8 Nov 2023 16:19:58 +0100 Subject: [PATCH] fix snowflake connector --- dlt/destinations/snowflake/configuration.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/dlt/destinations/snowflake/configuration.py b/dlt/destinations/snowflake/configuration.py index 66c2f82282..4d9aaa7b54 100644 --- a/dlt/destinations/snowflake/configuration.py +++ b/dlt/destinations/snowflake/configuration.py @@ -88,7 +88,7 @@ def to_connector_params(self) -> Dict[str, Any]: private_key: Optional[bytes] = None if self.private_key: private_key = _read_private_key(self.private_key, self.private_key_passphrase) - return dict( + conn_params = dict( self.query or {}, user=self.username, password=self.password, @@ -97,8 +97,10 @@ def to_connector_params(self) -> Dict[str, Any]: warehouse=self.warehouse, role=self.role, private_key=private_key, - authenticator=self.authenticator, ) + if self.authenticator: + conn_params["authenticator"] = self.authenticator + return conn_params @configspec