|
16 | 16 | from reactivex.scheduler import ThreadPoolScheduler |
17 | 17 | from reactivex.subject import Subject |
18 | 18 |
|
19 | | -from influxdb_client_3.write_client.domain import WritePrecision |
20 | 19 | from influxdb_client_3.write_client.client._base import _BaseWriteApi, _HAS_DATACLASS |
21 | 20 | from influxdb_client_3.write_client.client.util.helpers import get_org_query_param |
22 | 21 | from influxdb_client_3.write_client.client.write.dataframe_serializer import DataframeSerializer |
23 | 22 | from influxdb_client_3.write_client.client.write.point import Point, DEFAULT_WRITE_PRECISION |
24 | 23 | from influxdb_client_3.write_client.client.write.retry import WritesRetry |
| 24 | +from influxdb_client_3.write_client.domain import WritePrecision |
25 | 25 | from influxdb_client_3.write_client.rest import _UTF_8_encoding |
26 | 26 |
|
27 | 27 | logger = logging.getLogger('influxdb_client_3.write_client.client.write_api') |
@@ -467,8 +467,7 @@ def _write_batching(self, bucket, org, data, |
467 | 467 | precision, **kwargs) |
468 | 468 |
|
469 | 469 | elif isinstance(data, Point): |
470 | | - write_precision = data.write_precision if data.write_precision is not None else precision |
471 | | - self._write_batching(bucket, org, data.to_line_protocol(), write_precision, **kwargs) |
| 470 | + self._write_batching(bucket, org, data.to_line_protocol(), data.write_precision, **kwargs) |
472 | 471 |
|
473 | 472 | elif isinstance(data, dict): |
474 | 473 | self._write_batching(bucket, org, Point.from_dict(data, write_precision=precision, **kwargs), |
|
0 commit comments