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