Fixing flake8 issue.

This commit is contained in:
Josh Berkus
2015-09-03 21:46:06 -07:00
parent 6df56fc6cc
commit aeea7196bd
+2 -2
View File
@@ -382,8 +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])