diff --git a/iotdb-client/client-py/iotdb/Session.py b/iotdb-client/client-py/iotdb/Session.py index bad5064282032..23d1f65ccc73c 100644 --- a/iotdb-client/client-py/iotdb/Session.py +++ b/iotdb-client/client-py/iotdb/Session.py @@ -516,7 +516,7 @@ def insert_str_record(self, device_id, timestamp, measurements, string_values): ) measurements = list(filtered_measurements) values = list(filtered_values) - if len(measurements) is 0 or len(values) is 0: + if len(measurements) == 0 or len(values) == 0: logger.info("All inserting values are none!") return request = self.gen_insert_str_record_req( @@ -556,7 +556,7 @@ def insert_aligned_str_record( ) measurements = list(filtered_measurements) values = list(filtered_values) - if len(measurements) is 0 or len(values) is 0: + if len(measurements) == 0 or len(values) == 0: logger.info("All inserting values are none!") return request = self.gen_insert_str_record_req( @@ -605,7 +605,7 @@ def insert_record(self, device_id, timestamp, measurements, data_types, values): measurements = list(filtered_measurements) data_types = list(filtered_data_types) values = list(filtered_values) - if len(measurements) is 0 or len(data_types) is 0 or len(values) is 0: + if len(measurements) == 0 or len(data_types) == 0 or len(values) == 0: logger.info("All inserting values are none!") return request = self.gen_insert_record_req( @@ -651,7 +651,7 @@ def insert_records( ) = self.__filter_lists_by_values( device_ids, times, measurements_lst, types_lst, values_lst ) - if len(device_ids) is 0: + if len(device_ids) == 0: logger.info("All inserting values are none!") return if self.__enable_redirection: @@ -734,7 +734,7 @@ def insert_aligned_record( measurements = list(filtered_measurements) data_types = list(filtered_data_types) values = list(filtered_values) - if len(measurements) is 0 or len(data_types) is 0 or len(values) is 0: + if len(measurements) == 0 or len(data_types) == 0 or len(values) == 0: logger.info("All inserting values are none!") return request = self.gen_insert_record_req( @@ -780,7 +780,7 @@ def insert_aligned_records( ) = self.__filter_lists_by_values( device_ids, times, measurements_lst, types_lst, values_lst ) - if len(device_ids) is 0: + if len(device_ids) == 0: logger.info("All inserting values are none!") return if self.__enable_redirection: diff --git a/iotdb-client/client-py/iotdb/utils/IoTDBRpcDataSet.py b/iotdb-client/client-py/iotdb/utils/IoTDBRpcDataSet.py index b7e0613395c70..c2e1648dfa99c 100644 --- a/iotdb-client/client-py/iotdb/utils/IoTDBRpcDataSet.py +++ b/iotdb-client/client-py/iotdb/utils/IoTDBRpcDataSet.py @@ -25,6 +25,7 @@ from thrift.transport import TTransport from iotdb.thrift.rpc.IClientRPCService import TSFetchResultsReq, TSCloseOperationReq from iotdb.tsfile.utils.DateUtils import parse_int_to_date +from iotdb.utils.IoTDBConnectionException import IoTDBConnectionException from iotdb.utils.IoTDBConstants import TSDataType logger = logging.getLogger("IoTDB") @@ -417,6 +418,8 @@ def result_set_to_pandas(self): return df def fetch_results(self): + if self.__is_closed: + raise IoTDBConnectionException("This DataSet is already closed") self.__rows_index = 0 request = TSFetchResultsReq( self.__session_id,