fix snowflake connector (#742)

dlt-hub · Nov 8, 2023 · 2c65c83 · 2c65c83
1 parent 0a67439
commit 2c65c83
Showing 1 changed file with 4 additions and 2 deletions.
diff --git 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