From 4b94ea7f60c2d415c2ca2988ed396bddaf694264 Mon Sep 17 00:00:00 2001 From: Ryan Haunfelder Date: Sun, 12 Dec 2021 22:24:58 -0700 Subject: [PATCH] pass certificate path to api connection --- dbt/adapters/presto/connections.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/dbt/adapters/presto/connections.py b/dbt/adapters/presto/connections.py index 76b958a..78850ff 100644 --- a/dbt/adapters/presto/connections.py +++ b/dbt/adapters/presto/connections.py @@ -24,6 +24,7 @@ class PrestoCredentials(Credentials): user: str password: Optional[str] = None method: Optional[str] = None + cert: Optional[str] = None http_headers: Optional[Dict[str, str]] = None http_scheme: Optional[str] = None _ALIASES = { @@ -39,7 +40,7 @@ def unique_field(self): return self.host def _connection_keys(self): - return ('host', 'port', 'user', 'database', 'schema') + return ('host', 'port', 'user', 'database', 'schema', 'cert') class ConnectionWrapper(object): @@ -189,6 +190,7 @@ def open(cls, connection): auth=auth, isolation_level=IsolationLevel.AUTOCOMMIT ) + presto_conn._http_session.verify = credentials.cert connection.state = 'open' connection.handle = ConnectionWrapper(presto_conn) return connection