Skip to content

Commit c429927

Browse files
authored
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
1 parent 0d4e439 commit c429927

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

dbt/adapters/impala/__version__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,4 +12,4 @@
1212
# See the License for the specific language governing permissions and
1313
# limitations under the License.
1414

15-
version = "1.4.1"
15+
version = "1.4.2"

dbt/adapters/impala/connections.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -257,7 +257,7 @@ def open(cls, connection):
257257

258258
ImpalaConnectionManager.fetch_impala_version(connection.handle)
259259
except Exception as ex:
260-
logger.debug(f"Connection error {ex}")
260+
logger.error(f"Connection error {ex}")
261261
connection_ex = ex
262262
connection.state = ConnectionState.FAIL
263263
connection.handle = None

dbt/adapters/impala/impl.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,8 +108,8 @@ def list_relations_without_caching(
108108
return []
109109
else:
110110
description = "Error while retrieving information about"
111-
logger.debug(f"{description} {schema_relation}: {e.msg}")
112-
return []
111+
logger.error(f"{description} {schema_relation}: {e.msg}")
112+
raise e
113113

114114
relations = []
115115
for row in results:

setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ def _get_dbt_core_version():
4646

4747
package_name = "dbt-impala"
4848
# make sure this always matches dbt/adapters/dbt_impala/__version__.py
49-
package_version = "1.4.1"
49+
package_version = "1.4.2"
5050
description = """The Impala adapter plugin for dbt"""
5151

5252
dbt_core_version = _get_dbt_core_version()

0 commit comments

Comments
 (0)