diff --git a/tools/lib/logreader.py b/tools/lib/logreader.py index e86690f3c3..192ee8e6f2 100755 --- a/tools/lib/logreader.py +++ b/tools/lib/logreader.py @@ -9,6 +9,7 @@ import os import pathlib import re import sys +import tqdm import urllib.parse import warnings @@ -259,7 +260,8 @@ class LogReader: def run_across_segments(self, num_processes, func): with multiprocessing.Pool(num_processes) as pool: ret = [] - for p in pool.map(partial(self._run_on_segment, func), range(len(self.logreader_identifiers))): + num_segs = len(self.logreader_identifiers) + for p in tqdm.tqdm(pool.imap(partial(self._run_on_segment, func), range(num_segs)), total=num_segs): ret.extend(p) return ret