diff options
| author | Priit Kustala | 2009-04-27 13:44:58 +0000 |
|---|---|---|
| committer | Marko Kreen | 2009-04-28 11:58:31 +0000 |
| commit | 7cde7f93a654d996553c0c521dbbba49364cd2d4 (patch) | |
| tree | efca18b4eb90d8bbf98e621ef354d93552f55ff6 | |
| parent | 5f818fe0588657ae8a62d58d33a47412587809be (diff) | |
fix in admin.py in get_node_subscriber_list ... remove local_watermark column from select
| -rw-r--r-- | python/pgq/cascade/admin.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py index ffb61af3..d52d6879 100644 --- a/python/pgq/cascade/admin.py +++ b/python/pgq/cascade/admin.py @@ -683,7 +683,7 @@ class CascadeAdmin(skytools.AdminScript): def get_node_subscriber_list(self, node_name): """Fetch subscriber list from a node.""" - q = "select node_name, local_watermark from pgq_node.get_subscriber_info(%s)" + q = "select node_name from pgq_node.get_subscriber_info(%s)" db = self.get_node_database(node_name) rows = self.exec_query(db, q, [self.queue_name]) return [r['node_name'] for r in rows] |