File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -180,14 +180,16 @@ def _run(self):
180180 """
181181 try :
182182 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 :
184187 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
187189 self .logger .debug ('Flush interval deadline. Flushed batch.' )
188190
189191 try :
190- interval = self .flushing_interval_deadline - self . _get_time ()
192+ interval = self .flushing_interval_deadline - loop_time
191193 item = self .event_queue .get (True , interval )
192194
193195 if item is None :
You can’t perform that action at this time.
0 commit comments