Commitef89ed5

committed

Fix that blind fix.

1 parent87a0491 commitef89ed5Copy full SHA for ef89ed5

File tree

-7

lines changed

-7

lines changed

Lines changed: 5 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -186,19 +186,17 @@ def catchup(self, username=None):`
`186`	`186`	`Args:`
`187`	`187`	`username: remote node's user name.`
`188`	`188`	`"""`
`189`		`-`
`190`	`189`	`try:`
`191`		`-pub_lsn=pub.node.execute(query="select pg_current_wal_lsn()::text from pg_catalog.pg_stat_replication",`
`192`		`-dbname=None,`
`193`		`-username=None)# yapf: disable`
	`190`	`+pub_lsn=self.pub.node.execute(query="select pg_current_wal_lsn()",`
	`191`	`+dbname=None,`
	`192`	`+username=None)[0][0]# yapf: disable`
`194`	`193`	`# create dummy xact`
`195`		`-pub.node.execute(query="select txid_current()",dbname=None,username=None)`
	`194`	`+self.pub.node.execute(query="select txid_current()",dbname=None,username=None)`
`196`	`195`	`query="""`
`197`		`- select{} - replay_lsn <= 0`
	`196`	`+ select'{}'::pg_lsn - replay_lsn <= 0`
`198`	`197`	`from pg_catalog.pg_stat_replication where application_name = '{}'`
`199`	`198`	`""".format(pub_lsn,self.name)`
`200`	`199`
`201`		`-`
`202`	`200`	`# wait until this LSN reaches subscriber`
`203`	`201`	`self.pub.node.poll_query_until(`
`204`	`202`	`query=query,`

Comments

(0)