Merge pull request #266 from zalando/feature/do_not_drop_active_slots

Do not drop active replication slots.
This commit is contained in:
Oleksii Kliukin
2016-08-24 11:50:57 +02:00
committed by GitHub
+1 -1
View File
@@ -900,7 +900,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):