X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=dak%2Fshow_new.py;h=2ec2c3518bae47d43c3104eba8f54561be416d7e;hb=4d902498b114e9397c4d00274b3a9df24dd215dc;hp=89d2e82c98b080e11eba9063c27c5f899cbdbc96;hpb=a7f77393881783e65423f1f36778c67c52e5213d;p=dak.git diff --git a/dak/show_new.py b/dak/show_new.py index 89d2e82c..2ec2c351 100755 --- a/dak/show_new.py +++ b/dak/show_new.py @@ -249,18 +249,19 @@ def init(session): ################################################################################ def main(): + examine_package.use_html = True pool = DakProcessPool(processes=5) session = DBConn().session() upload_ids = [ u.id for u in init(session) ] session.close() - examine_package.use_html=1 - - p = pool.map_async(do_pkg, upload_ids) + for upload_id in upload_ids: + pool.apply_async(do_pkg, [upload_id]) pool.close() - p.wait(timeout=600) + #p.wait(timeout=600) + pool.join() for htmlfile in htmlfiles_to_process: with open(htmlfile, "w") as fd: fd.write(timeout_str)