status: forgot to drop cstr_extra argument
authorMarko Kreen <markokr@gmail.com>
Fri, 22 Mar 2013 15:43:47 +0000 (17:43 +0200)
committerMarko Kreen <markokr@gmail.com>
Fri, 22 Mar 2013 15:43:47 +0000 (17:43 +0200)
python/pgq/cascade/admin.py

index dd9b670bb0463e948574f99031cbb11f718dad30..9eefcdfc137ad61a26690886ed280447a47c08dc 100644 (file)
@@ -449,7 +449,7 @@ class CascadeAdmin(skytools.AdminScript):
         num_threads = max (min (num_nodes / 4, 100), 1)
         tlist = []
         for i in range(num_threads):
-            t = threading.Thread (target = self._cmd_status_worker, args = (members, nodes, cstr_extra))
+            t = threading.Thread (target = self._cmd_status_worker, args = (members, nodes))
             t.daemon = True
             t.start()
             tlist.append(t)
@@ -466,7 +466,7 @@ class CascadeAdmin(skytools.AdminScript):
 
         self.queue_info.print_tree()
 
-    def _cmd_status_worker (self, members, nodes, cstr_extra):
+    def _cmd_status_worker (self, members, nodes):
         # members in, nodes out, both thread-safe
         while True:
             try: