We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 431bcb6 commit e14097bCopy full SHA for e14097b
1 file changed
pyiceberg/catalog/hive.py
@@ -160,7 +160,7 @@
160
class _HiveClient:
161
"""Helper class to nicely open and close the transport."""
162
163
- _transport: TTransport.TTransportBase
+ _transport: TTransport
164
_ugi: Optional[List[str]]
165
_hive_version: HiveVersion = HiveVersion(4, 0, 0)
166
_hms_v3: object
@@ -187,7 +187,7 @@ def _get_hive_version(self) -> HiveVersion:
187
version = map(int, open_client.getVersion().split("."))
188
return HiveVersion(*version)
189
190
- def _init_thrift_transport(self) -> TTransport.TTransportBase:
+ def _init_thrift_transport(self) -> TTransport:
191
url_parts = urlparse(self._uri)
192
if not url_parts.hostname or not url_parts.port:
193
raise ValueError("hive hostname and port must be set")
0 commit comments