Commitcb202c8

committed

clean up recovery tests

1 parentccbe62c commitcb202c8Copy full SHA for cb202c8

File tree

-5

lines changed

-5

lines changed

Lines changed: 0 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -40,8 +40,6 @@ def print_agg(self):`
`40`	`40`
`41`	`41`	`columns= ['running','running_latency','max_latency','finish']`
`42`	`42`
`43`		`-#rows = [ k+str(i+1) for k in agg.keys() for i, agg in enumerate(aggs)]`
`44`		`-`
`45`	`43`	`print("\t\t",end="")`
`46`	`44`	`forcolincolumns:`
`47`	`45`	`print(col,end="\t")`

Lines changed: 8 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -39,9 +39,6 @@ def test_2_node_disconnect(self):`
`39`	`39`	`subprocess.check_call(['blockade','partition','node3'])`
`40`	`40`	`print('Node3 disconnected')`
`41`	`41`
`42`		`-# give cluster some time to discover problem`
`43`		`-time.sleep(3)`
`44`		`-`
`45`	`42`	`foriinrange(5):`
`46`	`43`	`time.sleep(3)`
`47`	`44`	`forclientinself.clients:`
`@@ -53,6 +50,14 @@ def test_2_node_disconnect(self):`
`53`	`50`	`subprocess.check_call(['blockade','join'])`
`54`	`51`	`self.clients.stop()`
`55`	`52`
	`53`	`+subprocess.check_call(['blockade','join'])`
	`54`	`+print("Node3 joined back")`
	`55`	`+`
	`56`	`+foriinrange(50):`
	`57`	`+time.sleep(3)`
	`58`	`+self.clients.print_agg()`
	`59`	`+`
	`60`	`+`
`56`	`61`	`if__name__=='__main__':`
`57`	`62`	`unittest.main()`
`58`	`63`

Comments

(0)