Skip to content

Commit 9b34a51

Browse files
authored
Merge branch 'master' into point-equality
2 parents 63435b7 + 8286f45 commit 9b34a51

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

CHANGELOG.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,9 @@
33
### Features
44
1. [#625](https://github.com/influxdata/influxdb-client-python/pull/625) Make class `Point` equatable
55

6+
### Bug Fixes
7+
1. [#562](https://github.com/influxdata/influxdb-client-python/pull/562): Use `ThreadPoolScheduler` for `WriteApi`'s batch subject instead of `TimeoutScheduler` to prevent creating unnecessary threads repeatedly
8+
69
## 1.39.0 [2023-12-05]
710

811
### Features

influxdb_client/client/write_api.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,8 @@ def __init__(self,
258258
self._disposable = self._subject.pipe(
259259
# Split incoming data to windows by batch_size or flush_interval
260260
ops.window_with_time_or_count(count=write_options.batch_size,
261-
timespan=timedelta(milliseconds=write_options.flush_interval)),
261+
timespan=timedelta(milliseconds=write_options.flush_interval),
262+
scheduler=ThreadPoolScheduler(1)),
262263
# Map window into groups defined by 'organization', 'bucket' and 'precision'
263264
ops.flat_map(lambda window: window.pipe(
264265
# Group window by 'organization', 'bucket' and 'precision'

0 commit comments

Comments
 (0)