londiste: show table counts in 'status'

diff --git a/python/londiste/setup.py b/python/londiste/setup.py
index e8b203101d33dbcf98c619ddbf19a08ab1655803..fc1ddd58b8c6fdfbfa330e99c1175a5e153987e5 100644 (file)
--- a/python/londiste/setup.py
+++ b/python/londiste/setup.py
@@ -453,3 +453,17 @@ class LondisteSetup(CascadeAdmin):
             raise UsageError("Cannot proceed")
         return res_list
 
+    def load_extra_status(self, curs, node):
+        """Fetch extra info."""
+        CascadeAdmin.load_extra_status(self, curs, node)
+        curs.execute("select * from londiste.get_table_list(%s)", [self.queue_name])
+        n_ok = n_half = n_ign = 0
+        for tbl in curs.fetchall():
+            if not tbl['local']:
+                n_ign += 1
+            elif tbl['merge_state'] == 'ok':
+                n_ok += 1
+            else:
+                n_half += 1
+        node.add_info_line('Tables: %d/%d/%d' % (n_ok, n_half, n_ign))
+

diff --git a/python/pgq/cascade/nodeinfo.py b/python/pgq/cascade/nodeinfo.py
index 97d24f36062938a97f9a4b58eb4998ed262ae48c..96794bb55ab5a314336e3bd4542c7a08a6fa3630 100644 (file)
--- a/python/pgq/cascade/nodeinfo.py
+++ b/python/pgq/cascade/nodeinfo.py
@@ -100,7 +100,7 @@ class NodeInfo:
             lag = self.queue_info['ticker_lag']
         else:
             lag = "(n/a)"
-        txt = "lag: %s" % lag
+        txt = "Lag: %s" % lag
         if self.paused:
             txt += ", PAUSED"
         if not self.uptodate: