- #pool = Pool(processes=1)
- for changes_file in changes_files:
- changes_file = utils.validate_changes_file_arg(changes_file, 0)
- if not changes_file:
- continue
- print "\n" + changes_file
- #pool.apply_async(do_pkg, (changes_file,))
- do_pkg(changes_file)
- #pool.close()
- #pool.join()
+ pool = DakProcessPool(processes=5)
+ p = pool.map_async(do_pkg, changes_files)
+ pool.close()
+ p.wait(timeout=600)
+ for htmlfile in htmlfiles_to_process:
+ with open(htmlfile, "w") as fd:
+ fd.write(timeout_str)