@@ -33,7 +33,7 @@ def assertCommits(self, aggs):
33
33
commits = commits and 'commit' in agg ['transfer' ]['finish' ]
34
34
if not commits :
35
35
print ('No commits during aggregation interval' )
36
- # time.sleep(100000)
36
+ time .sleep (100000 )
37
37
raise AssertionError ('No commits during aggregation interval' )
38
38
39
39
def assertNoCommits (self , aggs ):
@@ -133,17 +133,17 @@ def test_node_partition(self):
133
133
self .assertCommits (aggs )
134
134
self .assertIsolation (aggs )
135
135
136
- # def test_edge_partition(self):
137
- # print('### test_edge_partition ###')
136
+ def test_edge_partition (self ):
137
+ print ('### test_edge_partition ###' )
138
138
139
- # aggs_failure, aggs = self.performFailure(EdgePartition('node2', 'node3'))
139
+ aggs_failure , aggs = self .performFailure (EdgePartition ('node2' , 'node3' ))
140
140
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 )
144
144
145
- # self.assertCommits(aggs)
146
- # self.assertIsolation(aggs)
145
+ self .assertCommits (aggs )
146
+ self .assertIsolation (aggs )
147
147
148
148
def test_node_restart (self ):
149
149
print ('### test_node_restart ###' )
0 commit comments