diff options
| author | Marko Kreen | 2011-01-24 15:26:27 +0000 |
|---|---|---|
| committer | Marko Kreen | 2011-01-24 15:28:51 +0000 |
| commit | fcb647e6de92d4792d9071facb60772a7e7952ef (patch) | |
| tree | 1e10ce9420c21500533900f242c60ff59ebde9fb /python/pgq | |
| parent | b20888d6e5e0c2e750cb1a31d8e20ec592be88e7 (diff) | |
pgq/cascade/admin: make tag-dead store into db
Diffstat (limited to 'python/pgq')
| -rw-r--r-- | python/pgq/cascade/admin.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py index 6f3e21ba..c09eb625 100644 --- a/python/pgq/cascade/admin.py +++ b/python/pgq/cascade/admin.py @@ -642,7 +642,11 @@ class CascadeAdmin(skytools.AdminScript): def cmd_tag_dead(self, node_name): # todo: write to db self.log.info("Tagging node '%s' as dead" % node_name) + self.load_local_info() self.queue_info.tag_dead(node_name) + q = "select * from pgq_node.register_location(%s, %s, null, true)" + self.node_cmd(self.local_node, q, [self.queue_name, node_name]) + # fixme: root? def cmd_pause(self): """Pause a node""" @@ -658,8 +662,9 @@ class CascadeAdmin(skytools.AdminScript): def cmd_members(self): """Show member list.""" + self.load_local_info() db = self.get_database(self.initial_db_name) - desc = 'Member info on %s:' % self.local_node + desc = 'Member info on %s@%s:' % (self.local_node, self.queue_name) q = "select node_name, dead, node_location"\ " from pgq_node.get_queue_locations(%s) order by 1" self.display_table(db, desc, q, [self.queue_name]) |