Another try at the is_healthiest_node bugfix.

This commit is contained in:
Josh Berkus
2015-09-03 21:41:33 -07:00
parent 2b62adae21
commit 6df56fc6cc
+2 -1
View File
@@ -382,7 +382,8 @@ recovery_target_timeline = 'latest'
self.query("""SELECT pg_create_physical_replication_slot(%s)
WHERE NOT EXISTS (SELECT 1 FROM pg_replication_slots
WHERE slot_name = %s)""", slot, slot)
self.members = members
self.members = members
def create_replication_slots(self, cluster):
self.sync_replication_slots([m.name for m in cluster.members if m.name != self.name])