Remove workerQueue unfinished tasks (#302)

splunk · Oct 8, 2019 · 48c25c4 · 48c25c4
1 parent e36b1f8
commit 48c25c4
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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"):