fix: dispose window scheduler

influxdata · Feb 29, 2024 · 6c530eb · 6c530eb
1 parent 9832cae
commit 6c530eb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/influxdb_client/client/write_api.py b/influxdb_client/client/write_api.py
@@ -250,6 +250,7 @@ def __init__(self,
         self._success_callback = kwargs.get('success_callback', None)
         self._error_callback = kwargs.get('error_callback', None)
         self._retry_callback = kwargs.get('retry_callback', None)
+        self._window_scheduler = None
 
         if self._write_options.write_type is WriteType.batching:
             # Define Subject that listen incoming data and produces writes into InfluxDB