diff --git a/splunk_eventgen/eventgen_core.py b/splunk_eventgen/eventgen_core.py
index 3db57660..b5c8cf6d 100644
--- a/splunk_eventgen/eventgen_core.py
+++ b/splunk_eventgen/eventgen_core.py
@@ -489,8 +489,7 @@ def check_done(self):
 
         :return: if eventgen jobs are finished, return True else False
         '''
-        return self.sampleQueue.empty() and self.sampleQueue.unfinished_tasks <= 0 and \
-            self.workerQueue.empty() and self.workerQueue.unfinished_tasks <= 0
+        return self.sampleQueue.empty() and self.sampleQueue.unfinished_tasks <= 0 and self.workerQueue.empty()
 
     def kill_processes(self):
         if self.args.multiprocess and hasattr(self, "pool"):