@@ -33,7 +33,7 @@ def assertCommits(self, aggs):
3333commits = commits and 'commit' in agg ['transfer' ]['finish' ]
3434if not commits :
3535print ('No commits during aggregation interval' )
36- # time.sleep(100000)
36+ time .sleep (100000 )
3737raise AssertionError ('No commits during aggregation interval' )
3838
3939def assertNoCommits (self ,aggs ):
@@ -133,17 +133,17 @@ def test_node_partition(self):
133133self .assertCommits (aggs )
134134self .assertIsolation (aggs )
135135
136- # def test_edge_partition(self):
137- # print('### test_edge_partition ###')
136+ def test_edge_partition (self ):
137+ print ('### test_edge_partition ###' )
138138
139- # aggs_failure, aggs = self.performFailure(EdgePartition('node2', 'node3'))
139+ aggs_failure ,aggs = self .performFailure (EdgePartition ('node2' ,'node3' ))
140140
141- # self.assertTrue( ('commit' in aggs_failure[1]['transfer']['finish']) or ('commit' in aggs_failure[2]['transfer']['finish']) )
142- # self.assertCommits(aggs_failure[0:1]) # first node
143- # self.assertIsolation(aggs_failure)
141+ self .assertTrue ( ('commit' in aggs_failure [1 ]['transfer' ]['finish' ])or ('commit' in aggs_failure [2 ]['transfer' ]['finish' ]) )
142+ self .assertCommits (aggs_failure [0 :1 ])# first node
143+ self .assertIsolation (aggs_failure )
144144
145- # self.assertCommits(aggs)
146- # self.assertIsolation(aggs)
145+ self .assertCommits (aggs )
146+ self .assertIsolation (aggs )
147147
148148def test_node_restart (self ):
149149print ('### test_node_restart ###' )