#700 fix so all processes join

ckan · Jul 15, 2013 · ceb1652 · ceb1652
1 parent 479aee4
commit ceb1652
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ckan/lib/cli.py b/ckan/lib/cli.py
@@ -438,8 +438,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