From de122e7208d111258da3d1137fda138e3731c382 Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 16:20:11 +0700 Subject: [PATCH 1/3] chore: add annotations for python3.8 --- influxdb_client_3/write_client/client/write_api.py | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 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..83e0dcd 100644 --- a/influxdb_client_3/write_client/client/write_api.py +++ b/influxdb_client_3/write_client/client/write_api.py @@ -1,6 +1,9 @@ """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 @@ -297,7 +300,7 @@ def __init__(self, You can use native asynchronous version of the client: - https://influxdb-client.readthedocs.io/en/stable/usage.html#how-to-use-asyncio """ -# TODO above message has link to Influxdb2 API __NOT__ Influxdb3 API !!! - illustrates different API + # TODO above message has link to Influxdb2 API __NOT__ Influxdb3 API !!! - illustrates different API warnings.warn(message, DeprecationWarning) def write(self, bucket: str, org: str = None, @@ -420,14 +423,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 +457,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 369701e34ab281d8175c9f699b65255bff3102cb Mon Sep 17 00:00:00 2001 From: NguyenHoangSon96 Date: Wed, 7 Jan 2026 16:30:31 +0700 Subject: [PATCH 2/3] chore: CHANGELOG.md --- CHANGELOG.md | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index f0d5598..8919a27 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -27,6 +27,7 @@ - Remove incorrect symbol `>>` for config.yml. - Added spacing for `<<` and `>>` just for consistency. 1. [176](https://github.com/InfluxCommunity/influxdb3-python/pull/176): Use `ConstantFlightServerDelayed` for timeout tests. +1. [#183](https://github.com/InfluxCommunity/influxdb3-python/pull/183): Temporarily add annotation to support Python 3.8. ## 0.16.0 [2025-09-15] From cae56f0c1dfd6586c2189cb7cd8020dd631d2995 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jakub=20Bedn=C3=A1=C5=99?= Date: Wed, 7 Jan 2026 11:44:48 +0100 Subject: [PATCH 3/3] fix: formatting and add missing pull request number --- CHANGELOG.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 8919a27..3e86575 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -26,7 +26,7 @@ 1. [#167](https://github.com/InfluxCommunity/influxdb3-python/pull/167): - Remove incorrect symbol `>>` for config.yml. - Added spacing for `<<` and `>>` just for consistency. -1. [176](https://github.com/InfluxCommunity/influxdb3-python/pull/176): Use `ConstantFlightServerDelayed` for timeout tests. +1. [#176](https://github.com/InfluxCommunity/influxdb3-python/pull/176): Use `ConstantFlightServerDelayed` for timeout tests. 1. [#183](https://github.com/InfluxCommunity/influxdb3-python/pull/183): Temporarily add annotation to support Python 3.8. ## 0.16.0 [2025-09-15]