Skip to content

Commit

Permalink
DBT-758: Raise the exception if the metadata scan failed for any table (
Browse files Browse the repository at this point in the history
#188)

* DBT-758: Raise the exception if the metadata scan failed for any table

* Updated package version
  • Loading branch information
niteshy authored Feb 8, 2024
1 parent 0d4e439 commit c429927
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion dbt/adapters/impala/__version__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"
2 changes: 1 addition & 1 deletion dbt/adapters/impala/connections.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions dbt/adapters/impala/impl.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down

0 comments on commit c429927

Please sign in to comment.