Skip to content

Commit cfafab1

Browse files
committed
Fixing int64 type conversions.
Signed-off-by: forestmvey <forestv@bitquilltech.com>
1 parent 0ae07dd commit cfafab1

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

tools/python/liveanalytics_influxdb3_migration_plugin/liveanalytics_migration_plugin/liveanalytics_migration_plugin.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -471,7 +471,7 @@ def ingest_parquet_file_in_chunks(
471471
column_types.append(("int64", field.name))
472472
else:
473473
column_types.append(("skip", field.name))
474-
df_chunk = batch.to_pandas()
474+
df_chunk = batch.to_pandas(types_mapper={pa.int64(): pandas.Int64Dtype()}.get)
475475

476476
influxdb3_local.info(
477477
f"Processing Chunk {chunk_number} ({len(df_chunk):,} records)"

0 commit comments

Comments
 (0)