Skip to content

Commit e8300f7

Browse files
committed
fix: Fixed serialization of DataFrame with empty values #118
1 parent bb8e665 commit e8300f7

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

tests/test_WriteApiDataFrame.py

+9-4
Original file line numberDiff line numberDiff line change
@@ -101,10 +101,13 @@ def test_write_nan(self):
101101
columns=["actual_kw_price", "forecast_kw_price", "actual_general_use",
102102
"forecast_general_use"])
103103

104-
points = self.client.write_api(write_options=SYNCHRONOUS)\
105-
._data_frame_to_list_of_points(data_frame=data_frame,
106-
precision=None,
107-
data_frame_measurement_name='measurement')
104+
self.client.default_tags = None
105+
106+
write_api = self.client.write_api(write_options=SYNCHRONOUS)
107+
108+
points = write_api._data_frame_to_list_of_points(data_frame=data_frame,
109+
precision=None,
110+
data_frame_measurement_name='measurement')
108111

109112
self.assertEqual(4, len(points))
110113
self.assertEqual("measurement actual_kw_price=3.1955,actual_general_use=20.514305 1586044800000000000",
@@ -115,3 +118,5 @@ def test_write_nan(self):
115118
points[2])
116119
self.assertEqual("measurement forecast_kw_price=5.139563,forecast_general_use=19.79124 1586050200000000000",
117120
points[3])
121+
122+
write_api.__del__()

0 commit comments

Comments
 (0)