change-provider: move old-provider ops to the end

That means even if they fail, all the other nodes are already updated.

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."""