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