Skip to content

Commit 2433629

Browse files
committed
fix: write polars dataframe
1 parent 0303b3f commit 2433629

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

influxdb_client_3/write_client/client/write_api.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -461,7 +461,7 @@ def _write_batching(self, bucket, org, data,
461461
precision, **kwargs)
462462

463463
elif 'polars' in str(type(data)):
464-
from influxdb_client_3.write_client.client.write.dataframe_serializer import PolarsDataframeSerializer
464+
from influxdb_client_3.write_client.client.write.polars_dataframe_serializer import PolarsDataframeSerializer
465465
serializer = PolarsDataframeSerializer(data,
466466
self._point_settings, precision,
467467
self._write_options.batch_size, **kwargs)

0 commit comments

Comments
 (0)