(iotdb) branch query_v3_py updated: upadte

[haonan]

This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch query_v3_py
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/query_v3_py by this push:
     new e718424b449 upadte
e718424b449 is described below

commit e718424b449e3ed27414dc1b347da8c36bbb045a
Author: HTHou <hhao...@outlook.com>
AuthorDate: Tue Mar 25 19:38:21 2025 +0800

    upadte
---
 iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py | 8 ++++++--
 iotdb-client/client-py/tests/integration/test_todf.py   | 3 ---
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py 
b/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
index 10b81e1862f..8530fef5c20 100644
--- a/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
+++ b/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
@@ -252,7 +252,9 @@ class IoTDBRpcDataSet(object):
             self.__query_result_index += 1
             if self.ignore_timestamp is None or self.ignore_timestamp is False:
                 if time_array.dtype.byteorder == ">" and len(time_array) > 0:
-                    
time_array.byteswap().view(time_array.dtype.newbyteorder("<"))
+                    time_array = time_array.byteswap().view(
+                        time_array.dtype.newbyteorder("<")
+                    )
                 result[0].append(time_array)
 
             for i, location in enumerate(
@@ -270,7 +272,9 @@ class IoTDBRpcDataSet(object):
                         and len(data_array) > 0
                         and data_array.dtype.byteorder == ">"
                     ):
-                        
data_array.byteswap().view(data_array.dtype.newbyteorder("<"))
+                        data_array = data_array.byteswap().view(
+                            data_array.dtype.newbyteorder("<")
+                        )
                 # TEXT, STRING
                 elif data_type in (5, 11):
                     data_array = np.array([x.decode("utf-8") for x in 
column_array])
diff --git a/iotdb-client/client-py/tests/integration/test_todf.py 
b/iotdb-client/client-py/tests/integration/test_todf.py
index 42f90bce1b5..9cd8ad26e6b 100644
--- a/iotdb-client/client-py/tests/integration/test_todf.py
+++ b/iotdb-client/client-py/tests/integration/test_todf.py
@@ -213,9 +213,6 @@ def test_multi_fetch():
         session_data_set = session.execute_query_statement("SELECT ** FROM 
root.wt1")
         session_data_set.set_fetch_size(100)
         df_output = session_data_set.todf()
-        for col in df_output.columns:
-            dt = df_output[col].dtype
-            print(f"Column: {col}, Byte order: {dt}")
         df_output = df_output[df_input.columns.tolist()]
 
         session.close()