From c4299273e780f65aa709196e07072f0a169ac67d Mon Sep 17 00:00:00 2001 From: niteshy Date: Wed, 7 Feb 2024 17:20:25 -0800 Subject: [PATCH] DBT-758: Raise the exception if the metadata scan failed for any table (#188) * DBT-758: Raise the exception if the metadata scan failed for any table * Updated package version --- dbt/adapters/impala/__version__.py | 2 +- dbt/adapters/impala/connections.py | 2 +- dbt/adapters/impala/impl.py | 4 ++-- setup.py | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/dbt/adapters/impala/__version__.py b/dbt/adapters/impala/__version__.py index 7a0e94c..a1572b5 100644 --- a/dbt/adapters/impala/__version__.py +++ b/dbt/adapters/impala/__version__.py @@ -12,4 +12,4 @@ # See the License for the specific language governing permissions and # limitations under the License. -version = "1.4.1" +version = "1.4.2" diff --git a/dbt/adapters/impala/connections.py b/dbt/adapters/impala/connections.py index d67a30b..4fc38e5 100644 --- a/dbt/adapters/impala/connections.py +++ b/dbt/adapters/impala/connections.py @@ -257,7 +257,7 @@ def open(cls, connection): ImpalaConnectionManager.fetch_impala_version(connection.handle) except Exception as ex: - logger.debug(f"Connection error {ex}") + logger.error(f"Connection error {ex}") connection_ex = ex connection.state = ConnectionState.FAIL connection.handle = None diff --git a/dbt/adapters/impala/impl.py b/dbt/adapters/impala/impl.py index 7ec65e2..9c5619b 100644 --- a/dbt/adapters/impala/impl.py +++ b/dbt/adapters/impala/impl.py @@ -108,8 +108,8 @@ def list_relations_without_caching( return [] else: description = "Error while retrieving information about" - logger.debug(f"{description} {schema_relation}: {e.msg}") - return [] + logger.error(f"{description} {schema_relation}: {e.msg}") + raise e relations = [] for row in results: diff --git a/setup.py b/setup.py index 6cccf61..4862e5b 100644 --- a/setup.py +++ b/setup.py @@ -46,7 +46,7 @@ def _get_dbt_core_version(): package_name = "dbt-impala" # make sure this always matches dbt/adapters/dbt_impala/__version__.py -package_version = "1.4.1" +package_version = "1.4.2" description = """The Impala adapter plugin for dbt""" dbt_core_version = _get_dbt_core_version()