From c465f8f685b64f2038b7f274637091432a810a00 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Mon, 14 Nov 2011 12:44:31 +0200 Subject: [PATCH] change-provider: move old-provider ops to the end That means even if they fail, all the other nodes are already updated. --- python/pgq/cascade/admin.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py index f5693bc7..4213a51c 100644 --- a/python/pgq/cascade/admin.py +++ b/python/pgq/cascade/admin.py @@ -418,6 +418,9 @@ class CascadeAdmin(skytools.AdminScript): q = 'select * from pgq_node.change_consumer_provider(%s, %s, %s)' self.node_cmd(node, q, [self.queue_name, consumer, new_provider]) + # done + self.resume_consumer(node, consumer) + # unsubscribe from old provider if is_worker: q = "select * from pgq_node.unregister_subscriber(%s, %s)" @@ -426,9 +429,6 @@ class CascadeAdmin(skytools.AdminScript): q = "select * from pgq.unregister_consumer(%s, %s)" self.node_cmd(old_provider, q, [self.queue_name, consumer]) - # done - self.resume_consumer(node, consumer) - def cmd_rename_node(self, old_name, new_name): """Rename node.""" -- 2.39.5