We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bb45d1e commit 950bd17Copy full SHA for 950bd17
1 file changed
pyiceberg/catalog/hive.py
@@ -168,6 +168,10 @@ def _init_thrift_client(self) -> None:
168
self._client = Client(protocol)
169
170
def __enter__(self) -> Client:
171
+ # If the transport is closed, reinitialize it
172
+ if not self._transport.isOpen():
173
+ self._init_thrift_client()
174
+
175
self._transport.open()
176
if self._ugi:
177
self._client.set_ugi(*self._ugi)
0 commit comments