28 lines
1.4 KiB
Diff
28 lines
1.4 KiB
Diff
|
From e285e1592750bc9f5f9a73a5a7dc0f1274f545a9 Mon Sep 17 00:00:00 2001
|
||
|
From: Alexander Kukushkin <alexander.kukushkin@zalando.de>
|
||
|
Date: Mon, 28 Jan 2019 12:25:47 +0100
|
||
|
Subject: [PATCH] Always use replication=1, otherwise it is considered a
|
||
|
logical walsender
|
||
|
|
||
|
Fixes: https://github.com/zalando/patroni/issues/894
|
||
|
Fixes: https://github.com/zalando/patroni/issues/951
|
||
|
---
|
||
|
patroni/postgresql.py | 4 +---
|
||
|
1 file changed, 1 insertion(+), 3 deletions(-)
|
||
|
|
||
|
Index: patroni/patroni/postgresql.py
|
||
|
===================================================================
|
||
|
--- patroni.orig/patroni/postgresql.py
|
||
|
+++ patroni/patroni/postgresql.py
|
||
|
@@ -1254,9 +1254,7 @@ class Postgresql(object):
|
||
|
|
||
|
@contextmanager
|
||
|
def _get_replication_connection_cursor(self, host='localhost', port=5432, database=None, **kwargs):
|
||
|
- database = database or self._database
|
||
|
- replication = 'database' if self._major_version >= 90400 else 1
|
||
|
- with self._get_connection_cursor(host=host, port=int(port), database=database, replication=replication,
|
||
|
+ with self._get_connection_cursor(host=host, port=int(port), database=database or self._database, replication=1,
|
||
|
user=self._replication['username'], password=self._replication['password'],
|
||
|
connect_timeout=3, options='-c statement_timeout=2000') as cur:
|
||
|
yield cur
|