Skip to content

Commit 8def539

Browse files
committed
use patch to check version
1 parent d151f5e commit 8def539

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

pyiceberg/catalog/hive.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -412,14 +412,14 @@ def _create_hive_table(self, open_client: Client, hive_table: HiveTable) -> None
412412

413413
def _get_hive_table(self, open_client: Client, *, dbname: str, tbl_name: str) -> HiveTable:
414414
try:
415-
if all((self._client._hive_version.major >= 4, self._client._hive_version.minor > 0)):
415+
if all((self._client._hive_version.major >= 4, self._client._hive_version.patch > 0)):
416416
return open_client.get_table_req(GetTableRequest(dbName=dbname, tblName=tbl_name)).table
417417
return open_client.get_table(dbname=dbname, tbl_name=tbl_name)
418418
except NoSuchObjectException as e:
419419
raise NoSuchTableError(f"Table does not exists: {tbl_name}") from e
420420

421421
def _get_table_objects_by_name(self, open_client: Client, *, dbname: str, tbl_names: list[str]) -> list[HiveTable]:
422-
if all((self._client._hive_version.major >= 4, self._client._hive_version.minor > 0)):
422+
if all((self._client._hive_version.major >= 4, self._client._hive_version.patch > 0)):
423423
return open_client.get_table_objects_by_name_req(GetTablesRequest(dbName=dbname, tblNames=tbl_names)).tables
424424
return open_client.get_table_objects_by_name(dbname=dbname, tbl_names=tbl_names)
425425

0 commit comments

Comments
 (0)