Skip to content

Commit 431bcb6

Browse files
committed
use v3 in tests
1 parent 9e67d5d commit 431bcb6

3 files changed

Lines changed: 5 additions & 4 deletions

File tree

pyiceberg/catalog/hive.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -156,6 +156,7 @@
156156
v3type = importlib.import_module("hive_metastore.v3.ttypes")
157157
v4type = importlib.import_module("hive_metastore.v4.ttypes")
158158

159+
159160
class _HiveClient:
160161
"""Helper class to nicely open and close the transport."""
161162

tests/catalog/test_hive.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727

2828
import pytest
2929
import thrift.transport.TSocket
30-
from hive_metastore.v4.ttypes import (
30+
from hive_metastore.v3.ttypes import (
3131
AlreadyExistsException,
3232
EnvironmentContext,
3333
FieldSchema,
@@ -40,10 +40,10 @@
4040
SkewedInfo,
4141
StorageDescriptor,
4242
)
43-
from hive_metastore.v4.ttypes import (
43+
from hive_metastore.v3.ttypes import (
4444
Database as HiveDatabase,
4545
)
46-
from hive_metastore.v4.ttypes import (
46+
from hive_metastore.v3.ttypes import (
4747
Table as HiveTable,
4848
)
4949

tests/integration/test_reads.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
import pyarrow as pa
2727
import pyarrow.parquet as pq
2828
import pytest
29-
from hive_metastore.v4.ttypes import LockRequest, LockResponse, LockState, UnlockRequest
29+
from hive_metastore.v3.ttypes import LockRequest, LockResponse, LockState, UnlockRequest
3030
from pyarrow.fs import S3FileSystem
3131
from pydantic_core import ValidationError
3232
from pyspark.sql import SparkSession

0 commit comments

Comments
 (0)