From 9c50db21536373f9c47f5bc9f921e7cb0d820845 Mon Sep 17 00:00:00 2001 From: Hanna Liashchuk Date: Wed, 18 Jan 2023 15:18:04 +0200 Subject: [PATCH] fix commit --- dbt/adapters/spark/connections.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/dbt/adapters/spark/connections.py b/dbt/adapters/spark/connections.py index 4712000e6..556f10a2f 100644 --- a/dbt/adapters/spark/connections.py +++ b/dbt/adapters/spark/connections.py @@ -117,8 +117,8 @@ def __post_init__(self): ) if ( - self.method == SparkConnectionMethod.HTTP - or self.method == SparkConnectionMethod.THRIFT + self.method == SparkConnectionMethod.HTTP + or self.method == SparkConnectionMethod.THRIFT ) and not (ThriftState and THttpClient and hive): raise dbt.exceptions.DbtRuntimeError( f"{self.method} connection method requires " @@ -379,7 +379,10 @@ def open(cls, connection): kerberos_service_name=creds.kerberos_service_name, password=creds.password, ) - conn = hive.connect(thrift_transport=transport, configuration=creds.server_side_parameters) + conn = hive.connect( + thrift_transport=transport, + configuration=creds.server_side_parameters + ) else: conn = hive.connect( host=creds.host,