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

Text spacing changes in an attempt to get flake8 to stop complaining.

Browse Source
This commit is contained in:
Josh Berkus
2015-09-03 21:04:42 -07:00
parent f5627a498e
commit 5f4a9ffabb
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
helpers/postgresql.py
+4 -5
View File
@@ -43,7 +43,6 @@ class Postgresql:
def __init__(self, config):
self.config = config
self.name = config['name']
self.scope = config['scope']
self.listen_addresses, self.port = config['listen'].split(':')
self.data_dir = config['data_dir']
@@ -257,8 +256,8 @@ class Postgresql:
member_conn = psycopg2.connect(**r)
member_conn.autocommit = True
member_cursor = member_conn.cursor()
member_cursor.execute(
"SELECT pg_is_in_recovery(), %s - pg_xlog_location_diff(pg_last_xlog_replay_location(),'0/0000000')",
member_cursor.execute("""SELECT pg_is_in_recovery(),
%s - pg_xlog_location_diff(pg_last_xlog_replay_location(),'0/0000000')""",
(self.xlog_position(), ))
row = member_cursor.fetchone()
member_cursor.close()
@@ -362,8 +361,8 @@ recovery_target_timeline = 'latest'
def xlog_position(self):
return self.query("""SELECT CASE WHEN pg_is_in_recovery()
THEN pg_xlog_location_diff(pg_last_xlog_replay_location(),'0/0000000')
ELSE pg_xlog_location_diff(pg_current_xlog_location(),'0/00000') END""").fetchone()[0]
THEN pg_xlog_location_diff(pg_last_xlog_replay_location(),'0/0000000')
ELSE pg_xlog_location_diff(pg_current_xlog_location(),'0/00000') END""").fetchone()[0]
def load_replication_slots(self):
if self.use_slots: