diff options
Diffstat (limited to 'python/pgq/cascade')
| -rw-r--r-- | python/pgq/cascade/admin.py | 6 |
1 files 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.""" |