dak/show_new.py: use apply_async instead of map_async

[dak.git] / dak / show_new.py

diff --git a/dak/show_new.py b/dak/show_new.py
index 89d2e82c98b080e11eba9063c27c5f899cbdbc96..2ec2c3518bae47d43c3104eba8f54561be416d7e 100755 (executable)
--- 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)