diff --git a/helpers/postgresql.py b/helpers/postgresql.py index 62c7bb7e..bc6aed5b 100644 --- a/helpers/postgresql.py +++ b/helpers/postgresql.py @@ -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])