better

yandex · Jul 30, 2024 · 81d9da7 · 81d9da7
1 parent 3f9d2f7
commit 81d9da7
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main.py b/src/main.py
@@ -200,6 +200,11 @@ def start(self):
         """
         Start iterations
         """
+        if (not self.config.getboolean('global', 'use_replication_slots') and
+                self.config.getboolean('global', 'replication_slots_polling')):
+            logging.warning('Force disable replication_slots_polling because use_replication_slots is disabled.')
+            self.config.set('global', 'replication_slots_polling', 'no')
+
         my_prio = self.config.get('global', 'priority')
         self.notifier.ready()
         while True: