diff --git a/splunk_handler/__init__.py b/splunk_handler/__init__.py index bdb9b14..42bc896 100644 --- a/splunk_handler/__init__.py +++ b/splunk_handler/__init__.py @@ -316,7 +316,7 @@ def empty_queue(self): del self.queue[:count] self.write_debug_log("Queue task completed") - return len(self.queue) > 0 + return len(self.queue) == 0 def force_flush(self): self.write_debug_log("Force flush requested")