fix: use ThreadPoolScheduler for WriteApi batch subject to prevent cr…

…eate threads repeteadly
influxdata · Aug 5, 2023 · 65ee74b · 65ee74b
1 parent a804c51
commit 65ee74b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/influxdb_client/client/write_api.py b/influxdb_client/client/write_api.py
@@ -258,7 +258,8 @@ def __init__(self,
             self._disposable = self._subject.pipe(
                 # Split incoming data to windows by batch_size or flush_interval
                 ops.window_with_time_or_count(count=write_options.batch_size,
-                                              timespan=timedelta(milliseconds=write_options.flush_interval)),
+                                              timespan=timedelta(milliseconds=write_options.flush_interval),
+                                              scheduler=ThreadPoolScheduler(1)),
                 # Map  window into groups defined by 'organization', 'bucket' and 'precision'
                 ops.flat_map(lambda window: window.pipe(
                     # Group window by 'organization', 'bucket' and 'precision'