From 00eb1000bb9f5c6837432538d305d0882134180d Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 15:23:19 +0700 Subject: [PATCH 1/7] [EMPTY] trigger CI From 5490e8d74c1c4f34991da2dd5779d641a9c1f487 Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 15:28:21 +0700 Subject: [PATCH 2/7] [EMPTY] trigger CI From 49594d1adf6014bbfdd23b86a0474f24d34d4e7e Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 15:31:04 +0700 Subject: [PATCH 3/7] chore: remove space blank lines --- influxdb_client_3/write_client/client/write_api.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/influxdb_client_3/write_client/client/write_api.py b/influxdb_client_3/write_client/client/write_api.py index 6fe6783..242c801 100644 --- a/influxdb_client_3/write_client/client/write_api.py +++ b/influxdb_client_3/write_client/client/write_api.py @@ -420,14 +420,15 @@ def _create_batching_pipeline(self) -> tuple[Subject[Any], rx.abc.DisposableBase # Create batch (concatenation line protocols by \n) ops.map(lambda group: group.pipe( # type: ignore ops.to_iterable(), - ops.map(lambda xs: _BatchItem(key=group.key, data=_body_reduce(xs), size=len(xs))))), # type: ignore + ops.map(lambda xs: _BatchItem(key=group.key, data=_body_reduce(xs), size=len(xs))))), + # type: ignore ops.merge_all())), # Write data into InfluxDB (possibility to retry if its fail) ops.filter(lambda batch: batch.size > 0), ops.map(mapper=lambda batch: self._to_response(data=batch, delay=self._jitter_delay())), ops.merge_all()) \ .subscribe(self._on_next, self._on_error, self._on_complete) - + return subject, disposable def flush(self): @@ -453,7 +454,7 @@ def close(self): """Flush data and dispose a batching buffer.""" if self._subject is None: return # Already closed - + self._subject.on_completed() self._subject.dispose() self._subject = None From 71b3665f2f1f063a7da5f9f601504390b381c640 Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 15:36:58 +0700 Subject: [PATCH 4/7] [EMPTY] trigger CI From 6fb492a1f1a32a420dd5146b50f2bacee8221b6b Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 15:49:17 +0700 Subject: [PATCH 5/7] chore: add annotations for python3.7 --- tests/test_api_client.py | 2 ++ tests/test_dataframe_serializer.py | 2 ++ tests/test_deep_merge.py | 2 ++ 3 files changed, 6 insertions(+) diff --git a/tests/test_api_client.py b/tests/test_api_client.py index 22a8b60..0f1c206 100644 --- a/tests/test_api_client.py +++ b/tests/test_api_client.py @@ -1,3 +1,5 @@ +from __future__ import annotations + import json import unittest import uuid diff --git a/tests/test_dataframe_serializer.py b/tests/test_dataframe_serializer.py index 7cb67e6..1f49a4d 100644 --- a/tests/test_dataframe_serializer.py +++ b/tests/test_dataframe_serializer.py @@ -1,3 +1,5 @@ +from __future__ import annotations + import unittest from datetime import timedelta from io import StringIO diff --git a/tests/test_deep_merge.py b/tests/test_deep_merge.py index 8f6e04c..d1e9c08 100644 --- a/tests/test_deep_merge.py +++ b/tests/test_deep_merge.py @@ -1,3 +1,5 @@ +from __future__ import annotations + import unittest import influxdb_client_3 From 28e58956b8ab2662eea5562fe376f4dff11004b9 Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 15:58:29 +0700 Subject: [PATCH 6/7] chore: add annotations for python3.8 --- tests/test_api_client.py | 2 +- tests/test_dataframe_serializer.py | 2 +- tests/test_deep_merge.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/test_api_client.py b/tests/test_api_client.py index 0f1c206..b67a56b 100644 --- a/tests/test_api_client.py +++ b/tests/test_api_client.py @@ -1,5 +1,5 @@ +# TODO Remove after this program no longer supports Python 3.8.* from __future__ import annotations - import json import unittest import uuid diff --git a/tests/test_dataframe_serializer.py b/tests/test_dataframe_serializer.py index 1f49a4d..5d493b4 100644 --- a/tests/test_dataframe_serializer.py +++ b/tests/test_dataframe_serializer.py @@ -1,5 +1,5 @@ +# TODO Remove after this program no longer supports Python 3.8.* from __future__ import annotations - import unittest from datetime import timedelta from io import StringIO diff --git a/tests/test_deep_merge.py b/tests/test_deep_merge.py index d1e9c08..243b5b6 100644 --- a/tests/test_deep_merge.py +++ b/tests/test_deep_merge.py @@ -1,5 +1,5 @@ +# TODO Remove after this program no longer supports Python 3.8.* from __future__ import annotations - import unittest import influxdb_client_3 From 0514de74da2ca35ad1bcb28e1be2e0cd3a5925fe Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 16:12:43 +0700 Subject: [PATCH 7/7] chore: add annotations for python3.8 --- influxdb_client_3/write_client/client/write_api.py | 2 ++ tests/test_api_client.py | 2 -- tests/test_dataframe_serializer.py | 2 -- tests/test_deep_merge.py | 2 -- 4 files changed, 2 insertions(+), 6 deletions(-) diff --git a/influxdb_client_3/write_client/client/write_api.py b/influxdb_client_3/write_client/client/write_api.py index 242c801..91cafc0 100644 --- a/influxdb_client_3/write_client/client/write_api.py +++ b/influxdb_client_3/write_client/client/write_api.py @@ -1,6 +1,8 @@ """Collect and write time series data to InfluxDB Cloud or InfluxDB OSS.""" # coding: utf-8 +# TODO Remove after this program no longer supports Python 3.8.* +from __future__ import annotations import logging import os import warnings diff --git a/tests/test_api_client.py b/tests/test_api_client.py index b67a56b..22a8b60 100644 --- a/tests/test_api_client.py +++ b/tests/test_api_client.py @@ -1,5 +1,3 @@ -# TODO Remove after this program no longer supports Python 3.8.* -from __future__ import annotations import json import unittest import uuid diff --git a/tests/test_dataframe_serializer.py b/tests/test_dataframe_serializer.py index 5d493b4..7cb67e6 100644 --- a/tests/test_dataframe_serializer.py +++ b/tests/test_dataframe_serializer.py @@ -1,5 +1,3 @@ -# TODO Remove after this program no longer supports Python 3.8.* -from __future__ import annotations import unittest from datetime import timedelta from io import StringIO diff --git a/tests/test_deep_merge.py b/tests/test_deep_merge.py index 243b5b6..8f6e04c 100644 --- a/tests/test_deep_merge.py +++ b/tests/test_deep_merge.py @@ -1,5 +1,3 @@ -# TODO Remove after this program no longer supports Python 3.8.* -from __future__ import annotations import unittest import influxdb_client_3