Skip to content

Commit d2afef8

Browse files
committed
fix: dispose window scheduler
1 parent e09a612 commit d2afef8

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

influxdb_client/client/write_api.py

+1
Original file line numberDiff line numberDiff line change
@@ -250,6 +250,7 @@ def __init__(self,
250250
self._success_callback = kwargs.get('success_callback', None)
251251
self._error_callback = kwargs.get('error_callback', None)
252252
self._retry_callback = kwargs.get('retry_callback', None)
253+
self._window_scheduler = None
253254

254255
if self._write_options.write_type is WriteType.batching:
255256
# Define Subject that listen incoming data and produces writes into InfluxDB

0 commit comments

Comments
 (0)