Commitf5c0980

committed

try to fix test_archive_replica_null_offset

1 parentcb19d6a commitf5c0980Copy full SHA for f5c0980

File tree

+11

-11

lines changed

+11

-11

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1677,8 +1677,8 @@ def switch_wal_segment(self, node, sleep_seconds=1, and_tx=False):`
`1677`	`1677`	`sleep(sleep_seconds)`
`1678`	`1678`
`1679`	`1679`	`@contextlib.contextmanager`
`1680`		`-defswitch_wal_after(self,node,seconds):`
`1681`		`-tm=threading.Timer(seconds,self.switch_wal_segment, [node,0,True])`
	`1680`	`+defswitch_wal_after(self,node,seconds,and_tx=True):`
	`1681`	`+tm=threading.Timer(seconds,self.switch_wal_segment, [node,0,and_tx])`
`1682`	`1682`	`tm.start()`
`1683`	`1683`	`try:`
`1684`	`1684`	`yield`

Lines changed: 9 additions & 9 deletions

Original file line number	Diff line number	Diff line change
`@@ -751,17 +751,17 @@ def test_archive_replica_null_offset(self):`
`751`	`751`
`752`	`752`	`replica.slow_start(replica=True)`
`753`	`753`
`754`		`-self.switch_wal_segment(master)`
`755`	`754`	`self.switch_wal_segment(master)`
`756`	`755`
`757`		`-# take backup from replica`
`758`		`-output=self.backup_node(`
`759`		`-backup_dir,'node',replica,replica.data_dir,`
`760`		`-options=[`
`761`		`-'--archive-timeout=30',`
`762`		`-'--log-level-console=LOG',`
`763`		`-'--no-validate'],`
`764`		`-return_id=False)`
	`756`	`+withself.switch_wal_after(master,10):`
	`757`	`+# take backup from replica`
	`758`	`+output=self.backup_node(`
	`759`	`+backup_dir,'node',replica,replica.data_dir,`
	`760`	`+options=[`
	`761`	`+'--archive-timeout=30',`
	`762`	`+'--log-level-console=LOG',`
	`763`	`+'--no-validate'],`
	`764`	`+return_id=False)`
`765`	`765`
`766`	`766`	`self.assertIn(`
`767`	`767`	`'LOG: Looking for LSN 0/4000000 in segment: 000000010000000000000003',`

Comments

(0)