mirror/python
1
0
Fork 0
mirror of https://github.com/meshtastic/python.git synced 2026-01-04 22:08:00 -05:00
Code Issues Packages Projects Releases Wiki Activity

always write using correct schema for the file

Browse Source
This commit is contained in:
Kevin Hester
2024-07-07 15:17:26 -07:00
parent 9297732806
commit 8c63f4dec6
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
meshtastic/slog/arrow.py
View File

@@ -46,7 +46,9 @@ class ArrowWriter:
# only need to look at the first row to learn the schema
self.set_schema(pa.Table.from_pylist([self.new_rows[0]]).schema)
self.writer.write_batch(pa.RecordBatch.from_pylist(self.new_rows))
self.writer.write_batch(
pa.RecordBatch.from_pylist(self.new_rows, schema=self.schema)
)
self.new_rows = []
def add_row(self, row_dict: dict):