This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch
4197-preserve-integer-timestamps-when-converting-dataframes-to-dataseries-in-queryresultfrom_pandas
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/4197-preserve-integer-timestamps-when-converting-dataframes-to-dataseries-in-queryresultfrom_pandas
by this push:
new 380f50882b fix: update row conversion to use numpy to avoid float for
timestamp
380f50882b is described below
commit 380f50882bf4bb79387a45c8e76018251e654490
Author: Philipp Zehnder <[email protected]>
AuthorDate: Tue Feb 24 13:42:37 2026 +0100
fix: update row conversion to use numpy to avoid float for timestamp
---
streampipes-client-python/streampipes/model/resource/query_result.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streampipes-client-python/streampipes/model/resource/query_result.py
b/streampipes-client-python/streampipes/model/resource/query_result.py
index 1b251e0017..040d94c7b8 100644
--- a/streampipes-client-python/streampipes/model/resource/query_result.py
+++ b/streampipes-client-python/streampipes/model/resource/query_result.py
@@ -128,7 +128,7 @@ class QueryResult(Resource):
raise StreamPipesUnsupportedDataSeries(f"First column must be
'timestamp', got {headers[0]!r}")
df["timestamp"] = df["timestamp"].astype("int64")
- rows = df.values.tolist()
+ rows = df.astype(object).to_numpy().tolist()
data_series = DataSeries(total=len(rows), headers=headers, rows=rows,
tags=None)
return cls(
