Searched refs:time_from_now (Results 1 – 2 of 2) sorted by relevance
118 def _schedule_flush_thread(self, time_from_now): argument120 if min_wait_sec > time_from_now:121 time_from_now = min_wait_sec122 logging.debug('Scheduling thread to run in %f seconds', time_from_now)124 time_from_now, self._flush)125 self._scheduled_flush_time = time.time() + time_from_now
125 def _schedule_flush_thread(self, time_from_now): argument127 if min_wait_sec > time_from_now:128 time_from_now = min_wait_sec129 logging.debug('Scheduling thread to run in %f seconds', time_from_now)130 self._scheduled_flush_thread = threading.Timer(time_from_now, self._flush)131 self._scheduled_flush_time = time.time() + time_from_now