Skip to content

Commit fbddbfe

Browse files
fix(hive): use validated metastore connection check in partition guard
1 parent a45d7dc commit fbddbfe

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • ingestion/src/metadata/ingestion/source/database/hive

ingestion/src/metadata/ingestion/source/database/hive/metadata.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,8 @@ def get_table_partition_details(
161161
# When metastore connection is configured, self.engine is a
162162
# MySQL/Postgres engine — DESCRIBE FORMATTED will fail against it.
163163
# Skip partition detection in this case.
164-
if getattr(self.service_connection, "metastoreConnection", None):
164+
metastore_conn = self._get_validated_metastore_connection()
165+
if metastore_conn:
165166
logger.debug(
166167
"Skipping partition key detection for"
167168
f" {schema_name}.{table_name}: metastoreConnection"

0 commit comments

Comments
 (0)