#700 fix so all processes join

ckan · Apr 1, 2013 · 4c46b57 · 4c46b57
1 parent 22750ff
commit 4c46b57
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ckan/lib/cli.py b/ckan/lib/cli.py
@@ -439,8 +439,8 @@ def chunks(l, n):
                 yield l[i*newn:i*newn+newn]
             yield l[n*newn-newn:]
 
+        processes = []
         for chunk in chunks(package_ids, mp.cpu_count()):
-            processes = []
             process = mp.Process(target=start, args=(chunk,))
             processes.append(process)
             process.daemon = True