diff --git a/patroni/postgresql.py b/patroni/postgresql.py index 7dff8b32..e04b8f45 100644 --- a/patroni/postgresql.py +++ b/patroni/postgresql.py @@ -884,7 +884,7 @@ $$""".format(name, ' '.join(options)), name, password, password) for slot in set(self._replication_slots) - set(slots): self.query("""SELECT pg_drop_replication_slot(%s) WHERE EXISTS(SELECT 1 FROM pg_replication_slots - WHERE slot_name = %s)""", slot, slot) + WHERE slot_name = %s AND NOT active)""", slot, slot) # create new slots for slot in set(slots) - set(self._replication_slots):