fix: deprecated method call

InfluxCommunity · Jul 3, 2024 · b16cab9 · b16cab9
1 parent a1a78ba
commit b16cab9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/influxdb_client_3/write_client/client/write/polars_dataframe_serializer.py b/influxdb_client_3/write_client/client/write/polars_dataframe_serializer.py
@@ -136,7 +136,7 @@ def serialize(self, chunk_idx: int = None):
             chunk = df[chunk_idx * self.chunk_size:(chunk_idx + 1) * self.chunk_size]
 
         # Apply the UDF to each row
-        line_protocol_expr = chunk.apply(self.to_line_protocol, return_dtype=pl.Object)
+        line_protocol_expr = chunk.map_rows(self.to_line_protocol, return_dtype=pl.Object)
 
         lp = line_protocol_expr['map'].to_list()