File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -175,8 +175,8 @@ def start(self):
175
175
self .executor .start ()
176
176
177
177
def _run (self ):
178
- """ Triggered as part of the thread which batches events or flushes event_queue and sleeps
179
- periodically if queue is empty.
178
+ """ Triggered as part of the thread which batches events or flushes event_queue and hangs on get
179
+ for flush interval if queue is empty.
180
180
"""
181
181
try :
182
182
while True :
@@ -221,7 +221,7 @@ def flush(self):
221
221
self .event_queue .put (self ._FLUSH_SIGNAL )
222
222
223
223
def _flush_batch (self ):
224
- """ Flushes event_queue by dispatching events . """
224
+ """ Flushes current batch by dispatching event . """
225
225
batch_len = len (self ._current_batch )
226
226
if batch_len == 0 :
227
227
self .logger .debug ('Nothing to flush.' )
You can’t perform that action at this time.
0 commit comments