fix progress not initialized bug

usc-isi-i2 · May 6, 2020 · 54e3e6c · 54e3e6c
1 parent d841110
commit 54e3e6c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pyrallel/parallel_processor.py b/pyrallel/parallel_processor.py
@@ -295,7 +295,8 @@ def add_task(self, *args, **kwargs):
         (main process, unblocked, using round robin to find next available queue)
         """
         self.batch_data.append((args, kwargs))
-        self.progress_thread.progress_info[ProgressThread.P_ADDED] += 1
+        if self.progress:
+            self.progress_thread.progress_info[ProgressThread.P_ADDED] += 1
 
         if len(self.batch_data) == self.batch_size:
             self._add_task(self.batch_data)