We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent abc546a commit d05b933Copy full SHA for d05b933
iotdb-client/client-py/iotdb/utils/IoTDBRpcDataSet.py
@@ -25,6 +25,7 @@
25
from thrift.transport import TTransport
26
from iotdb.thrift.rpc.IClientRPCService import TSFetchResultsReq, TSCloseOperationReq
27
from iotdb.tsfile.utils.DateUtils import parse_int_to_date
28
+from iotdb.utils.IoTDBConnectionException import IoTDBConnectionException
29
from iotdb.utils.IoTDBConstants import TSDataType
30
31
logger = logging.getLogger("IoTDB")
@@ -417,6 +418,8 @@ def result_set_to_pandas(self):
417
418
return df
419
420
def fetch_results(self):
421
+ if self.__is_closed:
422
+ raise IoTDBConnectionException("This DataSet is already closed")
423
self.__rows_index = 0
424
request = TSFetchResultsReq(
425
self.__session_id,
0 commit comments