Skip to content

Commit

Permalink
fix commit
Browse files Browse the repository at this point in the history
  • Loading branch information
hanna-liashchuk committed Jan 19, 2023
1 parent 6c5ebfb commit 0bbabe6
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions dbt/adapters/spark/connections.py
Original file line number Diff line number Diff line change
Expand Up @@ -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 "
Expand Down Expand Up @@ -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,
Expand Down

0 comments on commit 0bbabe6

Please sign in to comment.