7
7
from ydb .tests .library .common .types import Erasure
8
8
import yatest .common
9
9
10
+ from ydb .tests .library .common .types import Erasure
10
11
from ydb .tests .library .harness .util import LogLevels
11
12
from ydb .tests .library .harness .kikimr_config import KikimrConfigGenerator
12
13
from ydb .tests .library .harness .kikimr_runner import KiKiMR
17
18
18
19
logger = logging .getLogger (__name__ )
19
20
20
- class RestartNodesTest (object ):
21
+ class TestRestartNodes (object ):
21
22
@classmethod
22
23
def setup_class (cls ):
23
- nodes_count = 8 if cls .erasure == Erasure .BLOCK_4_2 else 9
24
- configurator = KikimrConfigGenerator (cls .erasure ,
24
+ # nodes_count = 8 if cls.erasure == Erasure.BLOCK_4_2 else 9
25
+ nodes_count = 8
26
+ configurator = KikimrConfigGenerator (None ,
25
27
nodes = nodes_count ,
26
28
use_in_memory_pdisks = False ,
27
29
additional_log_configs = {'CMS' : LogLevels .DEBUG },
@@ -95,7 +97,7 @@ def test(self):
95
97
threads : list [TestThread ] = []
96
98
# threads.append(TestThread(target=ydb_workload.bulk_upsert, args=[wait_time, 10, 1000, True]))
97
99
for i in range (10 ):
98
- thread .append (TestThread (target = self .create_table , args = [i ]))
100
+ threads .append (TestThread (target = self .create_table , args = [i ]))
99
101
100
102
for thread in threads :
101
103
thread .start ()
@@ -104,6 +106,8 @@ def test(self):
104
106
105
107
for node in self .cluster .nodes :
106
108
node .stop ()
109
+ # киляются с killom.
110
+ # тут уточнить, как это делать.
107
111
108
112
for node in self .cluster .nodes :
109
113
node .start ()
0 commit comments