Fix timestamp corruption with pyarrow 13 and over

[ML-6855](https://jira.iguazeng.com/browse/ML-6855)
v3io · Jul 1, 2024 · 36bdf9e · 36bdf9e
1 parent d7ccb94
commit 36bdf9e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/clients/py/v3io_frames/pbutils.py b/clients/py/v3io_frames/pbutils.py
@@ -241,7 +241,8 @@ def series2col_with_dtype(s, name, dtype):
     elif dtype == fpb.TIME:
         s = pd.to_datetime(s, utc=True)
         s = s.dt.tz_convert('UTC')
-        kw['times'] = s.astype(np.int64)
+        # ML-6855: this results in nanoseconds regardless of datetime granularity, unlike s.astype(np.int64)
+        kw['times'] = s.apply(lambda x: x.value)
         kw['dtype'] = fpb.TIME
     elif dtype == fpb.NULL:
         kw['dtype'] = fpb.NULL