gitops/patroni
1
0
Fork 0
mirror of https://github.com/outbackdingo/patroni.git synced 2026-08-25 14:53:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of github.com:CyberDem0n/governor into features/refactoring

Browse Source
This commit is contained in:
Alexander Kukushkin
2015-05-11 10:06:29 +02:00
parent b3d6997289 6d17d39776
commit 42d9c08c37
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
helpers/postgresql.py
+2 -2
View File
@@ -149,7 +149,7 @@ class Postgresql:
member_conn.autocommit = True
member_cursor = member_conn.cursor()
member_cursor.execute(
'SELECT %s::pg_lsn - pg_last_xlog_replay_location() AS bytes', (self.xlog_position(), ))
"SELECT %s - (pg_last_xlog_replay_location() - '0/0000000'::pg_lsn)", (self.xlog_position(), ))
xlog_diff = member_cursor.fetchone()[0]
logger.info([self.name, member['hostname'], xlog_diff])
if xlog_diff < 0:
@@ -234,7 +234,7 @@ primary_conninfo = '{}'
self.admin["username"], self.admin["password"]))
def xlog_position(self):
return self.query('SELECT pg_last_xlog_replay_location()').fetchone()[0]
return self.query("SELECT pg_last_xlog_replay_location() - '0/0000000'::pg_lsn").fetchone()[0]
def load_replication_slots(self):
cursor = self.query("SELECT slot_name FROM pg_replication_slots WHERE slot_type='physical'")