pgq.cascade.admin: fixed takeover ("cannot subscribe to itself")

diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py
index 623c72e7be28b5653220dfe68114ad0f6b24f394..a9d599eaa03c8ba2b5595f4a605d8e58123c6226 100644 (file)
--- a/python/pgq/cascade/admin.py
+++ b/python/pgq/cascade/admin.py
@@ -844,7 +844,8 @@ class CascadeAdmin(skytools.AdminScript):
         # switch subscribers around
         if self.options.all or failover:
             for n in self.find_subscribers_for(old_node_name):
-                self.node_change_provider(n, new_node_name)
+                if n != new_node_name:
+                    self.node_change_provider(n, new_node_name)
 
     def find_provider(self, node_name):
         if self.node_alive(node_name):
@@ -861,7 +862,7 @@ class CascadeAdmin(skytools.AdminScript):
         return self.find_root_node()
 
     def find_subscribers_for(self, parent_node_name):
-        """Find subscribers for particular node node."""
+        """Find subscribers for particular node."""
 
         # use dict to eliminate duplicates
         res = {}