better slots on dead iter

yandex · Nov 15, 2024 · 4ca0eed · 4ca0eed
1 parent d2420d1
commit 4ca0eed
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/__init__.py b/src/__init__.py
@@ -77,7 +77,7 @@ def read_config(filename=None, options=None):
             'certfile': None,
             'ca_cert': None,
             'verify_certs': 'no',
-            'drop_slot_countdown': 10,
+            'drop_slot_countdown': 300,
             'replication_slots_polling': None,
             'max_allowed_switchover_lag_ms': 60000,
         },

diff --git a/src/main.py b/src/main.py
@@ -877,6 +877,7 @@ def dead_iter(self, db_state, zk_state, is_actually_dead):
         holder = self.zk.get_current_lock_holder()
         if holder and holder != helpers.get_hostname():
             if role == 'replica' and holder == last_primary:
+                self._acquire_replication_source_slot_lock(last_primary)
                 logging.info('Seems that primary has not changed but PostgreSQL is dead. Starting it.')
                 return self.db.start_postgresql()