From 2c65c83b8a8a1f4814eb2b3678357d1129f98d84 Mon Sep 17 00:00:00 2001 From: David Scharf Date: Wed, 8 Nov 2023 18:41:43 +0100 Subject: [PATCH] fix snowflake connector (#742) --- 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