File tree 1 file changed +6
-4
lines changed
1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -180,14 +180,16 @@ def _run(self):
180
180
"""
181
181
try :
182
182
while True :
183
- if self ._get_time () >= self .flushing_interval_deadline :
183
+ loop_time = self ._get_time ()
184
+ loop_time_flush_interval = self ._get_time (self .flush_interval .total_seconds ())
185
+
186
+ if loop_time >= self .flushing_interval_deadline :
184
187
self ._flush_batch ()
185
- self .flushing_interval_deadline = self ._get_time () + \
186
- self ._get_time (self .flush_interval .total_seconds ())
188
+ self .flushing_interval_deadline = loop_time + loop_time_flush_interval
187
189
self .logger .debug ('Flush interval deadline. Flushed batch.' )
188
190
189
191
try :
190
- interval = self .flushing_interval_deadline - self . _get_time ()
192
+ interval = self .flushing_interval_deadline - loop_time
191
193
item = self .event_queue .get (True , interval )
192
194
193
195
if item is None :
You can’t perform that action at this time.
0 commit comments