Skip to content

Commit ac3a285

Browse files
committed
remove unneeded imports
1 parent ed8a3fe commit ac3a285

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

pyiceberg/catalog/hive.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -153,14 +153,11 @@
153153

154154
logger = logging.getLogger(__name__)
155155

156-
v3type = importlib.import_module("hive_metastore.v3.ttypes")
157-
v4type = importlib.import_module("hive_metastore.v4.ttypes")
158-
159156

160157
class _HiveClient:
161158
"""Helper class to nicely open and close the transport."""
162159

163-
_transport: TTransport
160+
_transport: TTransport.TTransportBase
164161
_ugi: Optional[List[str]]
165162
_hive_version: HiveVersion = HiveVersion(4, 0, 0)
166163
_hms_v3: object
@@ -187,7 +184,7 @@ def _get_hive_version(self) -> HiveVersion:
187184
version = map(int, open_client.getVersion().split("."))
188185
return HiveVersion(*version)
189186

190-
def _init_thrift_transport(self) -> TTransport:
187+
def _init_thrift_transport(self) -> TTransport.TTransportBase:
191188
url_parts = urlparse(self._uri)
192189
if not url_parts.hostname or not url_parts.port:
193190
raise ValueError("hive hostname and port must be set")

0 commit comments

Comments
 (0)