- pool = DakProcessPool()
- 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 = DakProcessPool(processes=5)
+ p = pool.map_async(do_pkg, changes_files)