added parallel result collection (fixed)

Author: rsexton2

basicrta/cluster.py

@@ -96,7 +96,7 @@ def collect_results(self, nproc=1):
         with (Pool(nproc, initializer=tqdm.set_lock,
                    initargs=(Lock(),)) as p):
             try:
-                for _ in tqdm(p.istarmap(self._single_result, dirs),
+                for _ in tqdm(p.imap(self._single_result, dirs),
                               total=len(dirs), position=0,
                               desc='overall progress'):
                     pass