diff --git a/dbt/adapters/impala/connections.py b/dbt/adapters/impala/connections.py index 1fa2059..edc1444 100644 --- a/dbt/adapters/impala/connections.py +++ b/dbt/adapters/impala/connections.py @@ -224,6 +224,20 @@ def open(cls, connection): retries=credentials.retries, ) auth_type = "kerberos" + elif ( + credentials.auth_type == "PLAIN" + or credentials.auth_type == "plain" + ): # plain type connection + handle = impala.dbapi.connect( + host=credentials.host, + port=credentials.port, + auth_mechanism="PLAIN", + use_ssl=credentials.use_ssl, + user=credentials.username, + password=credentials.password, + retries=credentials.retries, + ) + auth_type = "plain" else: # default, insecure connection handle = impala.dbapi.connect( host=credentials.host, diff --git a/setup.py b/setup.py index 810d322..35b28fe 100644 --- a/setup.py +++ b/setup.py @@ -67,7 +67,7 @@ def _get_dbt_core_version(): 'dbt-core~={}'.format(dbt_core_version), "impyla==0.18", "python-decouple>=3.6", - "kerberos>=1.3.0", + # "kerberos>=1.3.0", # Not required per README, doesn't work on Windows ], classifiers=[ "Development Status :: 4 - Beta",