diff --git a/src/loggly/base.py b/src/loggly/base.py index d231407..e164932 100644 --- a/src/loggly/base.py +++ b/src/loggly/base.py @@ -91,8 +91,8 @@ def log_buffer(self, payload): time.time() > self._last_flush + self.timeout if should_flush: self._flush_buffer() - def log_flush(self): - self._flush_buffer() + def log_flush(self, force = True): + self._flush_buffer(force = force) def _flush_buffer(self, force = False): # retrieves some references from the current instance that @@ -112,7 +112,7 @@ def _flush_buffer(self, force = False): # schedules the call log operation and then empties the buffer # so that it's no longer going to be used (flushed), notice that # in case there's no delayer available calls the method immediately - if self.delayer: self.delayer(call_log) + if self.delayer and not force: self.delayer(call_log) else: call_log() self._buffer = [] self._last_flush = time.time()