pgq.cascade.admin: amended threading

diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py
index a8236816884d87b5415455c615d409031872120e..ed44dad72884870838b48aac7078db679b89fd74 100644 (file)
--- a/python/pgq/cascade/admin.py
+++ b/python/pgq/cascade/admin.py
@@ -363,9 +363,10 @@ class CascadeAdmin(skytools.AdminScript):
         nodes = Queue.Queue()
 
         # launch workers and wait
-        n = min (members.qsize(), 1000)
+        n = max (min (members.qsize() >> 2, 100), 1)
         for i in range(n):
             t = threading.Thread (target = self._cmd_status_worker, args = (members, nodes))
+            t.daemon = True
             t.start()
         members.join()