sk_chunk_list = sklearn_pipeline_list[i:i+self.n_jobs*2]
if not sys.platform.startswith("win"):
pool = Pool(processes=self.n_jobs)
chunk_res = pool.map(_wrapped_cross_val_score, sk_chunk_list)
else:
chunk_res += map(_wrapped_cross_val_score, sk_chunk_list)
for res in chunk_res:
self._pbar.update(1)
After Change
if not sys.platform.startswith("win"):
pool = ProcessPool(processes=self.n_jobs)
res_imap = pool.imap(_wrapped_cross_val_score, sklearn_pipeline_list)
ini_pbar_n = self._pbar.n
// hacky way for pbar update by using imap in pathos.multiprocessing.ProcessPool
while True:
num_job_done = len(res_imap._items)
