diff --git a/pyhive/hive.py b/pyhive/hive.py index c1287488..cf702704 100644 --- a/pyhive/hive.py +++ b/pyhive/hive.py @@ -354,6 +354,9 @@ def client(self): def sessionHandle(self): return self._sessionHandle + def is_open(self): + return self._transport.isOpen() + def rollback(self): raise NotSupportedError("Hive does not have transactions") # pragma: no cover